allConsumerGroupsInfo | Kafka.Metadata |
allTopicsMetadata | Kafka.Metadata |
assignment | Kafka.Consumer |
autoCommit | Kafka.Consumer.Subscription, Kafka.Consumer |
bitraverseM | Kafka.Consumer.Types, Kafka.Consumer |
bmBrokerHost | Kafka.Metadata |
bmBrokerId | Kafka.Metadata |
bmBrokerPort | Kafka.Metadata |
BrokerAddress | |
1 (Type/Class) | Kafka.Types, Kafka.Consumer, Kafka.Producer |
2 (Data Constructor) | Kafka.Types, Kafka.Consumer, Kafka.Producer |
BrokerId | |
1 (Type/Class) | Kafka.Types, Kafka.Consumer, Kafka.Producer |
2 (Data Constructor) | Kafka.Types, Kafka.Consumer, Kafka.Producer |
BrokerMetadata | |
1 (Type/Class) | Kafka.Metadata |
2 (Data Constructor) | Kafka.Metadata |
brokersList | |
1 (Function) | Kafka.Consumer.ConsumerProperties, Kafka.Consumer |
2 (Function) | Kafka.Producer.ProducerProperties, Kafka.Producer |
ClientId | |
1 (Type/Class) | Kafka.Types, Kafka.Consumer, Kafka.Producer |
2 (Data Constructor) | Kafka.Types, Kafka.Consumer, Kafka.Producer |
clientId | Kafka.Consumer.ConsumerProperties, Kafka.Consumer |
closeConsumer | Kafka.Consumer |
closeProducer | Kafka.Producer |
commitAllOffsets | Kafka.Consumer |
commitOffsetMessage | Kafka.Consumer |
commitPartitionsOffsets | Kafka.Consumer |
committed | Kafka.Consumer |
compression | |
1 (Function) | Kafka.Consumer.ConsumerProperties, Kafka.Consumer |
2 (Function) | Kafka.Producer.ProducerProperties, Kafka.Producer |
ConsumerGroupId | |
1 (Type/Class) | Kafka.Consumer.Types, Kafka.Consumer |
2 (Data Constructor) | Kafka.Consumer.Types, Kafka.Consumer |
consumerGroupInfo | Kafka.Metadata |
ConsumerProperties | |
1 (Type/Class) | Kafka.Consumer.ConsumerProperties, Kafka.Consumer |
2 (Data Constructor) | Kafka.Consumer.ConsumerProperties, Kafka.Consumer |
ConsumerRecord | |
1 (Type/Class) | Kafka.Consumer.Types, Kafka.Consumer |
2 (Data Constructor) | Kafka.Consumer.Types, Kafka.Consumer |
cpCallbacks | Kafka.Consumer.ConsumerProperties, Kafka.Consumer |
cpLogLevel | Kafka.Consumer.ConsumerProperties, Kafka.Consumer |
cpProps | Kafka.Consumer.ConsumerProperties, Kafka.Consumer |
CreateTime | Kafka.Consumer.Types, Kafka.Consumer |
crKey | Kafka.Consumer.Types, Kafka.Consumer |
crMapKey | Kafka.Consumer.Types, Kafka.Consumer |
crMapKV | Kafka.Consumer.Types, Kafka.Consumer |
crMapValue | Kafka.Consumer.Types, Kafka.Consumer |
crOffset | Kafka.Consumer.Types, Kafka.Consumer |
crPartition | Kafka.Consumer.Types, Kafka.Consumer |
crTimestamp | Kafka.Consumer.Types, Kafka.Consumer |
crTopic | Kafka.Consumer.Types, Kafka.Consumer |
crValue | Kafka.Consumer.Types, Kafka.Consumer |
DebugAll | Kafka.Types, Kafka.Consumer, Kafka.Producer |
DebugBroker | Kafka.Types, Kafka.Consumer, Kafka.Producer |
DebugCgrp | Kafka.Types, Kafka.Consumer, Kafka.Producer |
DebugFeature | Kafka.Types, Kafka.Consumer, Kafka.Producer |
DebugFetch | Kafka.Types, Kafka.Consumer, Kafka.Producer |
DebugGeneric | Kafka.Types, Kafka.Consumer, Kafka.Producer |
DebugMetadata | Kafka.Types, Kafka.Consumer, Kafka.Producer |
DebugMsg | Kafka.Types, Kafka.Consumer, Kafka.Producer |
debugOptions | |
1 (Function) | Kafka.Consumer.ConsumerProperties, Kafka.Consumer |
2 (Function) | Kafka.Producer.ProducerProperties, Kafka.Producer |
DebugProtocol | Kafka.Types, Kafka.Consumer, Kafka.Producer |
DebugQueue | Kafka.Types, Kafka.Consumer, Kafka.Producer |
DebugSecurity | Kafka.Types, Kafka.Consumer, Kafka.Producer |
DebugTopic | Kafka.Types, Kafka.Consumer, Kafka.Producer |
deliveryErrorsCallback | Kafka.Producer.ProducerProperties, Kafka.Producer |
dumpKafkaConf | Kafka.Dump |
dumpTopicConf | Kafka.Dump |
Earliest | Kafka.Consumer.Types, Kafka.Consumer |
errorCallback | Kafka.Consumer.ConsumerProperties, Kafka.Consumer, Kafka.Producer.ProducerProperties, Kafka.Producer |
extraProp | Kafka.Consumer.ConsumerProperties, Kafka.Consumer |
extraProps | |
1 (Function) | Kafka.Consumer.ConsumerProperties, Kafka.Consumer |
2 (Function) | Kafka.Producer.ProducerProperties, Kafka.Producer |
extraSubscriptionProps | Kafka.Consumer.Subscription, Kafka.Consumer |
extraTopicProps | Kafka.Producer.ProducerProperties, Kafka.Producer |
flushProducer | Kafka.Producer |
giError | Kafka.Metadata |
giGroup | Kafka.Metadata |
giMembers | Kafka.Metadata |
giProtocol | Kafka.Metadata |
giProtocolType | Kafka.Metadata |
giState | Kafka.Metadata |
gmiAssignment | Kafka.Metadata |
gmiClientHost | Kafka.Metadata |
gmiClientId | Kafka.Metadata |
gmiMemberId | Kafka.Metadata |
gmiMetadata | Kafka.Metadata |
GroupAwaitingSync | Kafka.Metadata |
GroupDead | Kafka.Metadata |
GroupEmpty | Kafka.Metadata |
groupId | Kafka.Consumer.ConsumerProperties, Kafka.Consumer |
GroupInfo | |
1 (Type/Class) | Kafka.Metadata |
2 (Data Constructor) | Kafka.Metadata |
GroupMemberId | |
1 (Type/Class) | Kafka.Metadata |
2 (Data Constructor) | Kafka.Metadata |
GroupMemberInfo | |
1 (Type/Class) | Kafka.Metadata |
2 (Data Constructor) | Kafka.Metadata |
GroupPreparingRebalance | Kafka.Metadata |
GroupProtocol | |
1 (Type/Class) | Kafka.Metadata |
2 (Data Constructor) | Kafka.Metadata |
GroupProtocolType | |
1 (Type/Class) | Kafka.Metadata |
2 (Data Constructor) | Kafka.Metadata |
GroupStable | Kafka.Metadata |
GroupState | Kafka.Metadata |
Gzip | Kafka.Types, Kafka.Consumer, Kafka.Producer |
hPrintKafka | Kafka.Dump |
hPrintSupportedKafkaConf | Kafka.Dump |
KafkaBadConfiguration | Kafka.Types, Kafka.Consumer, Kafka.Producer |
KafkaBadSpecification | Kafka.Types, Kafka.Consumer, Kafka.Producer |
KafkaCompressionCodec | Kafka.Types, Kafka.Consumer, Kafka.Producer |
kafkaCompressionCodecToString | Kafka.Types, Kafka.Consumer, Kafka.Producer |
KafkaConsumer | |
1 (Type/Class) | Kafka.Consumer.Types, Kafka.Consumer |
2 (Data Constructor) | Kafka.Consumer.Types |
KafkaDebug | Kafka.Types, Kafka.Consumer, Kafka.Producer |
kafkaDebugToString | Kafka.Types, Kafka.Consumer, Kafka.Producer |
KafkaError | |
1 (Type/Class) | Kafka.Types, Kafka.Consumer, Kafka.Producer |
2 (Data Constructor) | Kafka.Types, Kafka.Consumer, Kafka.Producer |
KafkaInvalidConfigurationValue | Kafka.Types, Kafka.Consumer, Kafka.Producer |
KafkaInvalidReturnValue | Kafka.Types, Kafka.Consumer, Kafka.Producer |
KafkaLogAlert | Kafka.Types, Kafka.Consumer, Kafka.Producer |
KafkaLogCrit | Kafka.Types, Kafka.Consumer, Kafka.Producer |
KafkaLogDebug | Kafka.Types, Kafka.Consumer, Kafka.Producer |
KafkaLogEmerg | Kafka.Types, Kafka.Consumer, Kafka.Producer |
KafkaLogErr | Kafka.Types, Kafka.Consumer, Kafka.Producer |
KafkaLogInfo | Kafka.Types, Kafka.Consumer, Kafka.Producer |
KafkaLogLevel | Kafka.Types, Kafka.Consumer, Kafka.Producer |
KafkaLogNotice | Kafka.Types, Kafka.Consumer, Kafka.Producer |
KafkaLogWarning | Kafka.Types, Kafka.Consumer, Kafka.Producer |
KafkaMetadata | |
1 (Type/Class) | Kafka.Metadata |
2 (Data Constructor) | Kafka.Metadata |
KafkaProducer | |
1 (Type/Class) | Kafka.Producer.Types, Kafka.Producer |
2 (Data Constructor) | Kafka.Producer.Types |
KafkaResponseError | Kafka.Types, Kafka.Consumer, Kafka.Producer |
KafkaUnknownConfigurationKey | Kafka.Types, Kafka.Consumer, Kafka.Producer |
kcKafkaConf | Kafka.Consumer.Types, Kafka.Consumer |
kcKafkaPtr | Kafka.Consumer.Types, Kafka.Consumer |
kmBrokers | Kafka.Metadata |
kmOrigBroker | Kafka.Metadata |
kmTopics | Kafka.Metadata |
kpKafkaConf | Kafka.Producer.Types, Kafka.Producer |
kpKafkaPtr | Kafka.Producer.Types, Kafka.Producer |
kpTopicConf | Kafka.Producer.Types, Kafka.Producer |
Latest | Kafka.Consumer.Types, Kafka.Consumer |
LogAppendTime | Kafka.Consumer.Types, Kafka.Consumer |
logCallback | Kafka.Consumer.ConsumerProperties, Kafka.Consumer, Kafka.Producer.ProducerProperties, Kafka.Producer |
logLevel | |
1 (Function) | Kafka.Consumer.ConsumerProperties, Kafka.Consumer |
2 (Function) | Kafka.Producer.ProducerProperties, Kafka.Producer |
Lz4 | Kafka.Types, Kafka.Consumer, Kafka.Producer |
Millis | |
1 (Type/Class) | Kafka.Types, Kafka.Consumer, Kafka.Producer |
2 (Data Constructor) | Kafka.Types, Kafka.Consumer, Kafka.Producer |
newConsumer | Kafka.Consumer |
newProducer | Kafka.Producer |
noAutoCommit | Kafka.Consumer.ConsumerProperties, Kafka.Consumer |
noAutoOffsetStore | Kafka.Consumer.ConsumerProperties, Kafka.Consumer |
NoCompression | Kafka.Types, Kafka.Consumer, Kafka.Producer |
NoTimestamp | Kafka.Consumer.Types, Kafka.Consumer |
Offset | |
1 (Type/Class) | Kafka.Consumer.Types, Kafka.Consumer |
2 (Data Constructor) | Kafka.Consumer.Types, Kafka.Consumer |
OffsetCommit | |
1 (Type/Class) | Kafka.Consumer.Types, Kafka.Consumer |
2 (Data Constructor) | Kafka.Consumer.Types, Kafka.Consumer |
OffsetCommitAsync | Kafka.Consumer.Types, Kafka.Consumer |
offsetCommitCallback | Kafka.Consumer.ConsumerProperties, Kafka.Consumer |
OffsetReset | Kafka.Consumer.Types, Kafka.Consumer |
offsetReset | Kafka.Consumer.Subscription, Kafka.Consumer |
offsetsForTime | Kafka.Metadata |
offsetsForTime' | Kafka.Metadata |
OffsetStoreBroker | Kafka.Consumer.Types, Kafka.Consumer |
OffsetStoreFile | Kafka.Consumer.Types, Kafka.Consumer |
OffsetStoreMethod | Kafka.Consumer.Types, Kafka.Consumer |
OffsetStoreSync | Kafka.Consumer.Types, Kafka.Consumer |
OffsetSyncDisable | Kafka.Consumer.Types, Kafka.Consumer |
OffsetSyncImmediate | Kafka.Consumer.Types, Kafka.Consumer |
OffsetSyncInterval | Kafka.Consumer.Types, Kafka.Consumer |
PartitionId | |
1 (Type/Class) | Kafka.Types, Kafka.Consumer, Kafka.Producer |
2 (Data Constructor) | Kafka.Types, Kafka.Consumer, Kafka.Producer |
PartitionMetadata | |
1 (Type/Class) | Kafka.Metadata |
2 (Data Constructor) | Kafka.Metadata |
PartitionOffset | |
1 (Type/Class) | Kafka.Consumer.Types, Kafka.Consumer |
2 (Data Constructor) | Kafka.Consumer.Types, Kafka.Consumer |
PartitionOffsetBeginning | Kafka.Consumer.Types, Kafka.Consumer |
PartitionOffsetEnd | Kafka.Consumer.Types, Kafka.Consumer |
PartitionOffsetInvalid | Kafka.Consumer.Types, Kafka.Consumer |
PartitionOffsetStored | Kafka.Consumer.Types, Kafka.Consumer |
partitionWatermarkOffsets | Kafka.Metadata |
pausePartitions | Kafka.Consumer |
pmError | Kafka.Metadata |
pmInSyncReplicas | Kafka.Metadata |
pmLeader | Kafka.Metadata |
pmPartitionId | Kafka.Metadata |
pmReplicas | Kafka.Metadata |
pollConsumerEvents | Kafka.Consumer |
pollMessage | Kafka.Consumer |
position | Kafka.Consumer |
ppCallbacks | Kafka.Producer.ProducerProperties, Kafka.Producer |
ppKafkaProps | Kafka.Producer.ProducerProperties, Kafka.Producer |
ppLogLevel | Kafka.Producer.ProducerProperties, Kafka.Producer |
ppTopicProps | Kafka.Producer.ProducerProperties, Kafka.Producer |
prKey | Kafka.Producer.Types, Kafka.Producer |
produceMessage | Kafka.Producer |
produceMessageBatch | Kafka.Producer |
ProducePartition | Kafka.Producer.Types, Kafka.Producer |
ProducerProperties | |
1 (Type/Class) | Kafka.Producer.ProducerProperties, Kafka.Producer |
2 (Data Constructor) | Kafka.Producer.ProducerProperties, Kafka.Producer |
ProducerRecord | |
1 (Type/Class) | Kafka.Producer.Types, Kafka.Producer |
2 (Data Constructor) | Kafka.Producer.Types, Kafka.Producer |
prPartition | Kafka.Producer.Types, Kafka.Producer |
prTopic | Kafka.Producer.Types, Kafka.Producer |
prValue | Kafka.Producer.Types, Kafka.Producer |
queuedMaxMessagesKBytes | Kafka.Consumer.ConsumerProperties, Kafka.Consumer |
RdKafkaRespErrAllBrokersDown | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrAssignPartitions | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrAuthentication | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrBadCompression | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrBadMsg | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrBegin | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrBrokerNotAvailable | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrClusterAuthorizationFailed | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrConcurrentTransactions | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrConflict | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrCritSysResource | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrDestroy | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrDuplicateSequenceNumber | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrEnd | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrEndAll | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrExistingSubscription | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrFail | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrFs | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrGroupAuthorizationFailed | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrGroupCoordinatorNotAvailable | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrGroupLoadInProgress | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrIllegalGeneration | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrIllegalSaslState | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrInconsistentGroupProtocol | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrInProgress | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrIntr | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrInvalidArg | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrInvalidCommitOffsetSize | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrInvalidConfig | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrInvalidGroupId | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrInvalidMsg | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrInvalidMsgSize | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrInvalidPartitions | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrInvalidProducerEpoch | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrInvalidProducerIdMapping | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrInvalidReplicaAssignment | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrInvalidReplicationFactor | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrInvalidRequest | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrInvalidRequiredAcks | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrInvalidSessionTimeout | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrInvalidTimestamp | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrInvalidTransactionTimeout | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrInvalidTxnState | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrIsrInsuff | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrKeyDeserialization | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrKeySerialization | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrLeaderNotAvailable | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrMsgSizeTooLarge | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrMsgTimedOut | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrNetworkException | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrNodeUpdate | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrNoError | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrNoOffset | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrNotController | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrNotCoordinatorForGroup | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrNotEnoughReplicas | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrNotEnoughReplicasAfterAppend | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrNotImplemented | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrNotLeaderForPartition | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrOffsetMetadataTooLarge | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrOffsetOutOfRange | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrOperationNotAttempted | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrOutdated | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrOutOfOrderSequenceNumber | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrPartial | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrPartitionEof | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrPolicyViolation | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrPrevInProgress | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrQueueFull | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrRebalanceInProgress | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrRecordListTooLarge | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrReplicaNotAvailable | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrRequestTimedOut | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrResolve | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrRevokePartitions | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrSecurityDisabled | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrSsl | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrStaleCtrlEpoch | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrState | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrT | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrTimedOut | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrTimedOutQueue | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrTopicAlreadyExists | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrTopicAuthorizationFailed | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrTopicException | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrTransactionalIdAuthorizationFailed | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrTransactionCoordinatorFenced | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrTransport | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrUnknown | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrUnknownGroup | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrUnknownMemberId | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrUnknownPartition | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrUnknownProtocol | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrUnknownTopic | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrUnknownTopicOrPart | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrUnsupportedFeature | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrUnsupportedForMessageFormat | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrUnsupportedSaslMechanism | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrUnsupportedVersion | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrValueDeserialization | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrValueSerialization | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrWaitCache | Kafka.Consumer, Kafka.Producer |
RdKafkaRespErrWaitCoord | Kafka.Consumer, Kafka.Producer |
RebalanceAssign | Kafka.Consumer.Types, Kafka.Consumer |
RebalanceBeforeAssign | Kafka.Consumer.Types, Kafka.Consumer |
RebalanceBeforeRevoke | Kafka.Consumer.Types, Kafka.Consumer |
rebalanceCallback | Kafka.Consumer.ConsumerProperties, Kafka.Consumer |
RebalanceEvent | Kafka.Consumer.Types, Kafka.Consumer |
RebalanceRevoke | Kafka.Consumer.Types, Kafka.Consumer |
resumePartitions | Kafka.Consumer |
runConsumer | Kafka.Consumer |
runProducer | Kafka.Producer |
seek | Kafka.Consumer |
sendTimeout | Kafka.Producer.ProducerProperties, Kafka.Producer |
sequenceFirst | Kafka.Consumer.Types, Kafka.Consumer |
setCallback | |
1 (Function) | Kafka.Consumer.ConsumerProperties, Kafka.Consumer |
2 (Function) | Kafka.Producer.ProducerProperties, Kafka.Producer |
Snappy | Kafka.Types, Kafka.Consumer, Kafka.Producer |
SpecifiedPartition | Kafka.Producer.Types, Kafka.Producer |
storeOffsetMessage | Kafka.Consumer |
SubscribedPartitions | |
1 (Type/Class) | Kafka.Consumer.Types, Kafka.Consumer |
2 (Data Constructor) | Kafka.Consumer.Types, Kafka.Consumer |
SubscribedPartitionsAll | Kafka.Consumer.Types, Kafka.Consumer |
Subscription | |
1 (Type/Class) | Kafka.Consumer.Subscription, Kafka.Consumer |
2 (Data Constructor) | Kafka.Consumer.Subscription, Kafka.Consumer |
subscription | Kafka.Consumer |
suppressDisconnectLogs | |
1 (Function) | Kafka.Consumer.ConsumerProperties, Kafka.Consumer |
2 (Function) | Kafka.Producer.ProducerProperties, Kafka.Producer |
Timeout | |
1 (Type/Class) | Kafka.Types, Kafka.Consumer, Kafka.Producer |
2 (Data Constructor) | Kafka.Types, Kafka.Consumer, Kafka.Producer |
Timestamp | Kafka.Consumer.Types, Kafka.Consumer |
tmError | Kafka.Metadata |
tmPartitions | Kafka.Metadata |
tmTopicName | Kafka.Metadata |
topicCompression | Kafka.Producer.ProducerProperties, Kafka.Producer |
TopicMetadata | |
1 (Type/Class) | Kafka.Metadata |
2 (Data Constructor) | Kafka.Metadata |
topicMetadata | Kafka.Metadata |
TopicName | |
1 (Type/Class) | Kafka.Types, Kafka.Consumer, Kafka.Producer |
2 (Data Constructor) | Kafka.Types, Kafka.Consumer, Kafka.Producer |
topicOffsetsForTime | Kafka.Metadata |
TopicPartition | |
1 (Type/Class) | Kafka.Consumer.Types, Kafka.Consumer |
2 (Data Constructor) | Kafka.Consumer.Types, Kafka.Consumer |
topics | Kafka.Consumer.Subscription, Kafka.Consumer |
tpOffset | Kafka.Consumer.Types, Kafka.Consumer |
tpPartition | Kafka.Consumer.Types, Kafka.Consumer |
tpTopicName | Kafka.Consumer.Types, Kafka.Consumer |
traverseFirst | Kafka.Consumer.Types, Kafka.Consumer |
traverseFirstM | Kafka.Consumer.Types, Kafka.Consumer |
traverseM | Kafka.Consumer.Types, Kafka.Consumer |
UnassignedPartition | Kafka.Producer.Types, Kafka.Producer |
WatermarkOffsets | |
1 (Type/Class) | Kafka.Metadata |
2 (Data Constructor) | Kafka.Metadata |
watermarkOffsets | Kafka.Metadata |
watermarkOffsets' | Kafka.Metadata |
woHighWatermark | Kafka.Metadata |
woLowWatermark | Kafka.Metadata |
woPartitionId | Kafka.Metadata |
woTopicName | Kafka.Metadata |