Index
| 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.Producer, Kafka.Consumer |
| 2 (Data Constructor) | Kafka.Types, Kafka.Producer, Kafka.Consumer |
| BrokerId | |
| 1 (Type/Class) | Kafka.Types, Kafka.Producer, Kafka.Consumer |
| 2 (Data Constructor) | Kafka.Types, Kafka.Producer, Kafka.Consumer |
| BrokerMetadata | |
| 1 (Type/Class) | Kafka.Metadata |
| 2 (Data Constructor) | Kafka.Metadata |
| brokersList | |
| 1 (Function) | Kafka.Producer.ProducerProperties, Kafka.Producer |
| 2 (Function) | Kafka.Consumer.ConsumerProperties, Kafka.Consumer |
| ClientId | |
| 1 (Type/Class) | Kafka.Types, Kafka.Producer, Kafka.Consumer |
| 2 (Data Constructor) | Kafka.Types, Kafka.Producer, Kafka.Consumer |
| 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.Producer.ProducerProperties, Kafka.Producer |
| 2 (Function) | Kafka.Consumer.ConsumerProperties, Kafka.Consumer |
| 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.Producer, Kafka.Consumer |
| DebugBroker | Kafka.Types, Kafka.Producer, Kafka.Consumer |
| DebugCgrp | Kafka.Types, Kafka.Producer, Kafka.Consumer |
| DebugFeature | Kafka.Types, Kafka.Producer, Kafka.Consumer |
| DebugFetch | Kafka.Types, Kafka.Producer, Kafka.Consumer |
| DebugGeneric | Kafka.Types, Kafka.Producer, Kafka.Consumer |
| DebugMetadata | Kafka.Types, Kafka.Producer, Kafka.Consumer |
| DebugMsg | Kafka.Types, Kafka.Producer, Kafka.Consumer |
| debugOptions | |
| 1 (Function) | Kafka.Producer.ProducerProperties, Kafka.Producer |
| 2 (Function) | Kafka.Consumer.ConsumerProperties, Kafka.Consumer |
| DebugProtocol | Kafka.Types, Kafka.Producer, Kafka.Consumer |
| DebugQueue | Kafka.Types, Kafka.Producer, Kafka.Consumer |
| DebugSecurity | Kafka.Types, Kafka.Producer, Kafka.Consumer |
| DebugTopic | Kafka.Types, Kafka.Producer, Kafka.Consumer |
| deliveryErrorsCallback | Kafka.Producer.ProducerProperties, Kafka.Producer |
| dumpKafkaConf | Kafka.Dump |
| dumpTopicConf | Kafka.Dump |
| Earliest | Kafka.Consumer.Types, Kafka.Consumer |
| errorCallback | Kafka.Producer.ProducerProperties, Kafka.Producer, Kafka.Consumer.ConsumerProperties, Kafka.Consumer |
| extraProp | Kafka.Consumer.ConsumerProperties, Kafka.Consumer |
| extraProps | |
| 1 (Function) | Kafka.Producer.ProducerProperties, Kafka.Producer |
| 2 (Function) | Kafka.Consumer.ConsumerProperties, Kafka.Consumer |
| 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.Producer, Kafka.Consumer |
| hPrintKafka | Kafka.Dump |
| hPrintSupportedKafkaConf | Kafka.Dump |
| KafkaBadConfiguration | Kafka.Types, Kafka.Producer, Kafka.Consumer |
| KafkaBadSpecification | Kafka.Types, Kafka.Producer, Kafka.Consumer |
| KafkaCompressionCodec | Kafka.Types, Kafka.Producer, Kafka.Consumer |
| kafkaCompressionCodecToString | Kafka.Types, Kafka.Producer, Kafka.Consumer |
| KafkaConsumer | |
| 1 (Type/Class) | Kafka.Consumer.Types, Kafka.Consumer |
| 2 (Data Constructor) | Kafka.Consumer.Types |
| KafkaDebug | Kafka.Types, Kafka.Producer, Kafka.Consumer |
| kafkaDebugToString | Kafka.Types, Kafka.Producer, Kafka.Consumer |
| KafkaError | |
| 1 (Type/Class) | Kafka.Types, Kafka.Producer, Kafka.Consumer |
| 2 (Data Constructor) | Kafka.Types, Kafka.Producer, Kafka.Consumer |
| KafkaInvalidConfigurationValue | Kafka.Types, Kafka.Producer, Kafka.Consumer |
| KafkaInvalidReturnValue | Kafka.Types, Kafka.Producer, Kafka.Consumer |
| KafkaLogAlert | Kafka.Types, Kafka.Producer, Kafka.Consumer |
| KafkaLogCrit | Kafka.Types, Kafka.Producer, Kafka.Consumer |
| KafkaLogDebug | Kafka.Types, Kafka.Producer, Kafka.Consumer |
| KafkaLogEmerg | Kafka.Types, Kafka.Producer, Kafka.Consumer |
| KafkaLogErr | Kafka.Types, Kafka.Producer, Kafka.Consumer |
| KafkaLogInfo | Kafka.Types, Kafka.Producer, Kafka.Consumer |
| KafkaLogLevel | Kafka.Types, Kafka.Producer, Kafka.Consumer |
| KafkaLogNotice | Kafka.Types, Kafka.Producer, Kafka.Consumer |
| KafkaLogWarning | Kafka.Types, Kafka.Producer, Kafka.Consumer |
| 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.Producer, Kafka.Consumer |
| KafkaUnknownConfigurationKey | Kafka.Types, Kafka.Producer, Kafka.Consumer |
| 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.Producer.ProducerProperties, Kafka.Producer, Kafka.Consumer.ConsumerProperties, Kafka.Consumer |
| logLevel | |
| 1 (Function) | Kafka.Producer.ProducerProperties, Kafka.Producer |
| 2 (Function) | Kafka.Consumer.ConsumerProperties, Kafka.Consumer |
| Lz4 | Kafka.Types, Kafka.Producer, Kafka.Consumer |
| Millis | |
| 1 (Type/Class) | Kafka.Types, Kafka.Producer, Kafka.Consumer |
| 2 (Data Constructor) | Kafka.Types, Kafka.Producer, Kafka.Consumer |
| newConsumer | Kafka.Consumer |
| newProducer | Kafka.Producer |
| noAutoCommit | Kafka.Consumer.ConsumerProperties, Kafka.Consumer |
| noAutoOffsetStore | Kafka.Consumer.ConsumerProperties, Kafka.Consumer |
| NoCompression | Kafka.Types, Kafka.Producer, Kafka.Consumer |
| 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.Producer, Kafka.Consumer |
| 2 (Data Constructor) | Kafka.Types, Kafka.Producer, Kafka.Consumer |
| 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.Producer, Kafka.Consumer |
| RdKafkaRespErrAssignPartitions | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrAuthentication | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrBadCompression | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrBadMsg | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrBegin | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrBrokerNotAvailable | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrClusterAuthorizationFailed | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrConcurrentTransactions | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrConflict | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrCritSysResource | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrDestroy | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrDuplicateSequenceNumber | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrEnd | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrEndAll | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrExistingSubscription | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrFail | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrFs | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrGroupAuthorizationFailed | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrGroupCoordinatorNotAvailable | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrGroupLoadInProgress | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrIllegalGeneration | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrIllegalSaslState | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrInconsistentGroupProtocol | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrInProgress | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrIntr | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrInvalidArg | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrInvalidCommitOffsetSize | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrInvalidConfig | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrInvalidGroupId | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrInvalidMsg | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrInvalidMsgSize | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrInvalidPartitions | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrInvalidProducerEpoch | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrInvalidProducerIdMapping | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrInvalidReplicaAssignment | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrInvalidReplicationFactor | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrInvalidRequest | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrInvalidRequiredAcks | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrInvalidSessionTimeout | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrInvalidTimestamp | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrInvalidTransactionTimeout | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrInvalidTxnState | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrIsrInsuff | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrKeyDeserialization | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrKeySerialization | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrLeaderNotAvailable | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrMsgSizeTooLarge | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrMsgTimedOut | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrNetworkException | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrNodeUpdate | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrNoent | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrNoError | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrNoOffset | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrNotController | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrNotCoordinatorForGroup | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrNotEnoughReplicas | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrNotEnoughReplicasAfterAppend | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrNotImplemented | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrNotLeaderForPartition | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrOffsetMetadataTooLarge | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrOffsetOutOfRange | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrOperationNotAttempted | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrOutdated | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrOutOfOrderSequenceNumber | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrPartial | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrPartitionEof | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrPolicyViolation | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrPrevInProgress | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrQueueFull | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrReadOnly | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrRebalanceInProgress | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrRecordListTooLarge | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrReplicaNotAvailable | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrRequestTimedOut | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrResolve | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrRevokePartitions | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrSecurityDisabled | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrSsl | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrStaleCtrlEpoch | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrState | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrT | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrTimedOut | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrTimedOutQueue | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrTopicAlreadyExists | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrTopicAuthorizationFailed | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrTopicException | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrTransactionalIdAuthorizationFailed | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrTransactionCoordinatorFenced | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrTransport | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrUnderflow | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrUnknown | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrUnknownGroup | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrUnknownMemberId | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrUnknownPartition | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrUnknownProtocol | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrUnknownTopic | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrUnknownTopicOrPart | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrUnsupportedFeature | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrUnsupportedForMessageFormat | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrUnsupportedSaslMechanism | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrUnsupportedVersion | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrValueDeserialization | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrValueSerialization | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrWaitCache | Kafka.Producer, Kafka.Consumer |
| RdKafkaRespErrWaitCoord | Kafka.Producer, Kafka.Consumer |
| 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.Producer.ProducerProperties, Kafka.Producer |
| 2 (Function) | Kafka.Consumer.ConsumerProperties, Kafka.Consumer |
| Snappy | Kafka.Types, Kafka.Producer, Kafka.Consumer |
| 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.Producer.ProducerProperties, Kafka.Producer |
| 2 (Function) | Kafka.Consumer.ConsumerProperties, Kafka.Consumer |
| Timeout | |
| 1 (Type/Class) | Kafka.Types, Kafka.Producer, Kafka.Consumer |
| 2 (Data Constructor) | Kafka.Types, Kafka.Producer, Kafka.Consumer |
| 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.Producer, Kafka.Consumer |
| 2 (Data Constructor) | Kafka.Types, Kafka.Producer, Kafka.Consumer |
| 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 |
| unBrokerAddress | Kafka.Types, Kafka.Producer, Kafka.Consumer |
| unBrokerId | Kafka.Types, Kafka.Producer, Kafka.Consumer |
| unClientId | Kafka.Types, Kafka.Producer, Kafka.Consumer |
| unConsumerGroupId | Kafka.Consumer.Types, Kafka.Consumer |
| unMillis | Kafka.Types, Kafka.Producer, Kafka.Consumer |
| unOffset | Kafka.Consumer.Types, Kafka.Consumer |
| unPartitionId | Kafka.Types, Kafka.Producer, Kafka.Consumer |
| unTimeout | Kafka.Types, Kafka.Producer, Kafka.Consumer |
| unTopicName | Kafka.Types, Kafka.Producer, Kafka.Consumer |
| 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 |