Index

addKafkaAddress	Network.Kafka
ApiKey
1 (Type/Class)	Network.Kafka.Protocol
2 (Data Constructor)	Network.Kafka.Protocol
apiKey	Network.Kafka.Protocol
ApiVersion
1 (Type/Class)	Network.Kafka.Protocol
2 (Data Constructor)	Network.Kafka.Protocol
apiVersion	Network.Kafka.Protocol
Attributes
1 (Type/Class)	Network.Kafka.Protocol
2 (Data Constructor)	Network.Kafka.Protocol
Broker
1 (Type/Class)	Network.Kafka.Protocol
2 (Data Constructor)	Network.Kafka.Protocol
broker2address	Network.Kafka
brokerFields	Network.Kafka.Protocol
brokerHost	Network.Kafka.Protocol
brokerNode	Network.Kafka.Protocol
BrokerNotAvailable	Network.Kafka.Protocol
brokerPartitionInfo	Network.Kafka
brokerPort	Network.Kafka.Protocol
ClientId
1 (Type/Class)	Network.Kafka.Protocol
2 (Data Constructor)	Network.Kafka.Protocol
codec	Network.Kafka.Protocol
CompressionCodec	Network.Kafka.Protocol
compressionCodecFromValue	Network.Kafka.Protocol
ConsumerCoordinatorNotAvailableCode	Network.Kafka.Protocol
ConsumerGroup
1 (Type/Class)	Network.Kafka.Protocol
2 (Data Constructor)	Network.Kafka.Protocol
CorrelationId
1 (Type/Class)	Network.Kafka.Protocol
2 (Data Constructor)	Network.Kafka.Protocol
Crc
1 (Type/Class)	Network.Kafka.Protocol
2 (Data Constructor)	Network.Kafka.Protocol
createTopic	Network.Kafka
createTopic'	Network.Kafka
CreateTopicsReq	Network.Kafka.Protocol
CreateTopicsRequest
1 (Type/Class)	Network.Kafka.Protocol
2 (Data Constructor)	Network.Kafka.Protocol
createTopicsRequest	Network.Kafka
CreateTopicsResponse
1 (Data Constructor)	Network.Kafka.Protocol
2 (Type/Class)	Network.Kafka.Protocol
defaultCorrelationId	Network.Kafka
defaultMaxBytes	Network.Kafka
defaultMaxWaitTime	Network.Kafka
defaultMessageAttributes	Network.Kafka.Producer
defaultMessageCrc	Network.Kafka.Producer
defaultMessageKey	Network.Kafka.Producer
defaultMessageMagicByte	Network.Kafka.Producer
defaultMinBytes	Network.Kafka
defaultRequestTimeout	Network.Kafka
defaultRequiredAcks	Network.Kafka
Deserializable	Network.Kafka.Protocol
deserialize	Network.Kafka.Protocol
doRequest	Network.Kafka.Protocol
doRequest'	Network.Kafka.Protocol
EarliestTime	Network.Kafka
errorKafka	Network.Kafka.Protocol
expect	Network.Kafka
fetch	Network.Kafka.Consumer
fetch'	Network.Kafka.Consumer
fetchMessages	Network.Kafka.Consumer
FetchReq	Network.Kafka.Protocol
FetchRequest
1 (Type/Class)	Network.Kafka.Protocol
2 (Data Constructor)	Network.Kafka.Protocol
fetchRequest	Network.Kafka.Consumer
FetchResp	Network.Kafka.Protocol
FetchResponse
1 (Data Constructor)	Network.Kafka.Protocol
2 (Type/Class)	Network.Kafka.Protocol
fetchResponseByTopic	Network.Kafka.Protocol
fetchResponseFields	Network.Kafka.Protocol
fetchResponseMessageMembers	Network.Kafka.Protocol
fetchResponseMessages	Network.Kafka.Protocol
FetchRR	Network.Kafka.Protocol
findMetadataOrElse	Network.Kafka
findPartition	Network.Kafka.Protocol
findPartitionMetadata	Network.Kafka.Protocol
getLastOffset	Network.Kafka
getLastOffset'	Network.Kafka
getPartitionByKey	Network.Kafka.Producer
getRandPartition	Network.Kafka.Producer
getTopicPartitionLeader	Network.Kafka
GroupCoordinatorReq	Network.Kafka.Protocol
GroupCoordinatorRequest
1 (Type/Class)	Network.Kafka.Protocol
2 (Data Constructor)	Network.Kafka.Protocol
GroupCoordinatorResp	Network.Kafka.Protocol
GroupCoordinatorResponse
1 (Data Constructor)	Network.Kafka.Protocol
2 (Type/Class)	Network.Kafka.Protocol
groupMessagesToSet	Network.Kafka.Producer
Gzip	Network.Kafka.Protocol
Host
1 (Type/Class)	Network.Kafka.Protocol
2 (Data Constructor)	Network.Kafka.Protocol
hostKString	Network.Kafka.Protocol
hostString	Network.Kafka.Protocol
InvalidMessage	Network.Kafka.Protocol
InvalidMessageSize	Network.Kafka.Protocol
Isr
1 (Type/Class)	Network.Kafka.Protocol
2 (Data Constructor)	Network.Kafka.Protocol
Kafka	Network.Kafka
KafkaAddress	Network.Kafka
KafkaBytes	Network.Kafka.Protocol
kafkaByteString	Network.Kafka.Protocol
KafkaClientError	Network.Kafka
KafkaClientId	Network.Kafka
KafkaDeserializationError	Network.Kafka
KafkaError	Network.Kafka.Protocol
KafkaFailedToFetchMetadata	Network.Kafka
KafkaInvalidBroker	Network.Kafka
KafkaIOException	Network.Kafka
KafkaNoOffset	Network.Kafka
KafkaState
1 (Type/Class)	Network.Kafka
2 (Data Constructor)	Network.Kafka
KafkaString	Network.Kafka.Protocol
KafkaTime	Network.Kafka
KBytes	Network.Kafka.Protocol
Key
1 (Type/Class)	Network.Kafka.Protocol
2 (Data Constructor)	Network.Kafka.Protocol
keyBytes	Network.Kafka.Protocol
keyed	Network.Kafka.Protocol
KString	Network.Kafka.Protocol
kString	Network.Kafka.Protocol
LatestTime	Network.Kafka
Leader
1 (Type/Class)	Network.Kafka.Protocol
2 (Data Constructor)	Network.Kafka.Protocol
leaderId	Network.Kafka.Protocol
LeaderNotAvailable	Network.Kafka.Protocol
MagicByte
1 (Type/Class)	Network.Kafka.Protocol
2 (Data Constructor)	Network.Kafka.Protocol
makeKeyedMessage	Network.Kafka.Producer
makeMessage	Network.Kafka.Producer
makeRequest	Network.Kafka
MaxBytes
1 (Type/Class)	Network.Kafka.Protocol
2 (Data Constructor)	Network.Kafka.Protocol
MaxNumberOfOffsets
1 (Type/Class)	Network.Kafka.Protocol
2 (Data Constructor)	Network.Kafka.Protocol
MaxWaitTime
1 (Type/Class)	Network.Kafka.Protocol
2 (Data Constructor)	Network.Kafka.Protocol
Message
1 (Type/Class)	Network.Kafka.Protocol
2 (Data Constructor)	Network.Kafka.Protocol
messageFields	Network.Kafka.Protocol
messageKey	Network.Kafka.Protocol
messageKeyBytes	Network.Kafka.Protocol
MessageSet
1 (Type/Class)	Network.Kafka.Protocol
2 (Data Constructor)	Network.Kafka.Protocol
messageSet	Network.Kafka.Protocol
messageSetByPartition	Network.Kafka.Protocol
MessageSetMember
1 (Type/Class)	Network.Kafka.Protocol
2 (Data Constructor)	Network.Kafka.Protocol
messageSetMembers	Network.Kafka.Protocol
MessageSizeTooLarge	Network.Kafka.Protocol
messageValue	Network.Kafka.Protocol
Metadata
1 (Type/Class)	Network.Kafka.Protocol
2 (Data Constructor)	Network.Kafka.Protocol
metadata	Network.Kafka
metadata'	Network.Kafka
MetadataReq	Network.Kafka.Protocol
MetadataRequest
1 (Type/Class)	Network.Kafka.Protocol
2 (Data Constructor)	Network.Kafka.Protocol
MetadataResp	Network.Kafka.Protocol
MetadataResponse
1 (Data Constructor)	Network.Kafka.Protocol
2 (Type/Class)	Network.Kafka.Protocol
metadataResponseBrokers	Network.Kafka.Protocol
metadataResponseFields	Network.Kafka.Protocol
MetadataRR	Network.Kafka.Protocol
MinBytes
1 (Type/Class)	Network.Kafka.Protocol
2 (Data Constructor)	Network.Kafka.Protocol
mkKafkaState	Network.Kafka
nextOffset	Network.Kafka.Protocol
NoCompression	Network.Kafka.Protocol
NodeId
1 (Type/Class)	Network.Kafka.Protocol
2 (Data Constructor)	Network.Kafka.Protocol
nodeId	Network.Kafka.Protocol
NoError	Network.Kafka.Protocol
NotCoordinatorForConsumerCode	Network.Kafka.Protocol
NotLeaderForPartition	Network.Kafka.Protocol
Offset
1 (Type/Class)	Network.Kafka.Protocol
2 (Data Constructor)	Network.Kafka.Protocol
OffsetCommitReq	Network.Kafka.Protocol
OffsetCommitRequest
1 (Type/Class)	Network.Kafka.Protocol
2 (Data Constructor)	Network.Kafka.Protocol
OffsetCommitResp	Network.Kafka.Protocol
OffsetCommitResponse
1 (Data Constructor)	Network.Kafka.Protocol
2 (Type/Class)	Network.Kafka.Protocol
OffsetFetchReq	Network.Kafka.Protocol
OffsetFetchRequest
1 (Type/Class)	Network.Kafka.Protocol
2 (Data Constructor)	Network.Kafka.Protocol
OffsetFetchResp	Network.Kafka.Protocol
OffsetFetchResponse
1 (Data Constructor)	Network.Kafka.Protocol
2 (Type/Class)	Network.Kafka.Protocol
OffsetMetadataTooLargeCode	Network.Kafka.Protocol
OffsetOutOfRange	Network.Kafka.Protocol
OffsetReq	Network.Kafka.Protocol
OffsetRequest
1 (Type/Class)	Network.Kafka.Protocol
2 (Data Constructor)	Network.Kafka.Protocol
offsetRequest	Network.Kafka
OffsetResp	Network.Kafka.Protocol
OffsetResponse
1 (Data Constructor)	Network.Kafka.Protocol
2 (Type/Class)	Network.Kafka.Protocol
offsetResponseFields	Network.Kafka.Protocol
offsetResponseOffset	Network.Kafka.Protocol
OffsetRR	Network.Kafka.Protocol
OffsetsLoadInProgressCode	Network.Kafka.Protocol
ordinaryConsumerId	Network.Kafka.Consumer
OtherTime	Network.Kafka
palLeader	Network.Kafka
palPartition	Network.Kafka
palTopic	Network.Kafka
Partition
1 (Type/Class)	Network.Kafka.Protocol
2 (Data Constructor)	Network.Kafka.Protocol
partitionAndCollate	Network.Kafka.Producer
PartitionAndLeader
1 (Type/Class)	Network.Kafka
2 (Data Constructor)	Network.Kafka
partitionId	Network.Kafka.Protocol
PartitionMetadata
1 (Type/Class)	Network.Kafka.Protocol
2 (Data Constructor)	Network.Kafka.Protocol
partitionMetadataFields	Network.Kafka.Protocol
partitionMetadataLeader	Network.Kafka.Protocol
PartitionOffsetRequestInfo
1 (Type/Class)	Network.Kafka
2 (Data Constructor)	Network.Kafka
PartitionOffsets
1 (Type/Class)	Network.Kafka.Protocol
2 (Data Constructor)	Network.Kafka.Protocol
partitionOffsetsFields	Network.Kafka.Protocol
partitionsMetadata	Network.Kafka.Protocol
payload	Network.Kafka.Protocol
Port
1 (Type/Class)	Network.Kafka.Protocol
2 (Data Constructor)	Network.Kafka.Protocol
portId	Network.Kafka.Protocol
portInt	Network.Kafka.Protocol
prod	Network.Kafka.Producer
produce	Network.Kafka.Producer
produceCompressedMessages	Network.Kafka.Producer
produceMessages	Network.Kafka.Producer
ProduceReq	Network.Kafka.Protocol
ProduceRequest
1 (Type/Class)	Network.Kafka.Protocol
2 (Data Constructor)	Network.Kafka.Protocol
produceRequest	Network.Kafka.Producer
ProduceResp	Network.Kafka.Protocol
ProduceResponse
1 (Data Constructor)	Network.Kafka.Protocol
2 (Type/Class)	Network.Kafka.Protocol
produceResponseFields	Network.Kafka.Protocol
ProduceRR	Network.Kafka.Protocol
protocolTime	Network.Kafka
ReplicaId
1 (Type/Class)	Network.Kafka.Protocol
2 (Data Constructor)	Network.Kafka.Protocol
ReplicaNotAvailable	Network.Kafka.Protocol
Replicas
1 (Type/Class)	Network.Kafka.Protocol
2 (Data Constructor)	Network.Kafka.Protocol
ReplicationFactor
1 (Type/Class)	Network.Kafka.Protocol
2 (Data Constructor)	Network.Kafka.Protocol
ReqResp	Network.Kafka.Protocol
Request
1 (Type/Class)	Network.Kafka.Protocol
2 (Data Constructor)	Network.Kafka.Protocol
requestBytes	Network.Kafka.Protocol
RequestMessage	Network.Kafka.Protocol
RequestTimedOut	Network.Kafka.Protocol
RequiredAcks
1 (Type/Class)	Network.Kafka.Protocol
2 (Data Constructor)	Network.Kafka.Protocol
ResponseMessage	Network.Kafka.Protocol
runKafka	Network.Kafka
send	Network.Kafka.Producer
Serializable	Network.Kafka.Protocol
serialize	Network.Kafka.Protocol
setMessage	Network.Kafka.Protocol
setOffset	Network.Kafka.Protocol
StaleControllerEpochCode	Network.Kafka.Protocol
stateAddresses	Network.Kafka
stateBrokers	Network.Kafka
stateBufferSize	Network.Kafka
stateConnections	Network.Kafka
stateCorrelationId	Network.Kafka
stateName	Network.Kafka
stateRequestTimeout	Network.Kafka
stateRequiredAcks	Network.Kafka
stateTopicMetadata	Network.Kafka
stateWaitSize	Network.Kafka
stateWaitTime	Network.Kafka
tamMessage	Network.Kafka
tamPayload	Network.Kafka
tamTopic	Network.Kafka
Time
1 (Type/Class)	Network.Kafka.Protocol
2 (Data Constructor)	Network.Kafka.Protocol
timeInt	Network.Kafka.Protocol
Timeout
1 (Type/Class)	Network.Kafka.Protocol
2 (Data Constructor)	Network.Kafka.Protocol
TName	Network.Kafka.Protocol
tName	Network.Kafka.Protocol
TopicAlreadyExists	Network.Kafka.Protocol
TopicAndMessage
1 (Type/Class)	Network.Kafka
2 (Data Constructor)	Network.Kafka
TopicAndPartition
1 (Type/Class)	Network.Kafka
2 (Data Constructor)	Network.Kafka
TopicMetadata
1 (Type/Class)	Network.Kafka.Protocol
2 (Data Constructor)	Network.Kafka.Protocol
topicMetadataFields	Network.Kafka.Protocol
topicMetadataKafkaError	Network.Kafka.Protocol
topicMetadataName	Network.Kafka.Protocol
TopicName	Network.Kafka.Protocol
topicsMetadata	Network.Kafka.Protocol
TopicsResp	Network.Kafka.Protocol
topicsResponseFields	Network.Kafka.Protocol
TopicsRR	Network.Kafka.Protocol
tryKafka	Network.Kafka
Unknown	Network.Kafka.Protocol
UnknownTopicOrPartition	Network.Kafka.Protocol
UnsupportedCompressionType	Network.Kafka.Protocol
updateAllMetadata	Network.Kafka
updateMetadata	Network.Kafka
updateMetadatas	Network.Kafka
Value
1 (Type/Class)	Network.Kafka.Protocol
2 (Data Constructor)	Network.Kafka.Protocol
valueBytes	Network.Kafka.Protocol
withAddressHandle	Network.Kafka
withAnyHandle	Network.Kafka
withBrokerHandle	Network.Kafka
_brokerFields	Network.Kafka.Protocol
_codec	Network.Kafka.Protocol
_compressionCodec	Network.Kafka.Protocol
_CreateTopicsResponse	Network.Kafka.Protocol
_FetchResponse	Network.Kafka.Protocol
_fetchResponseFields	Network.Kafka.Protocol
_GroupCoordinatorResponse	Network.Kafka.Protocol
_hostKString	Network.Kafka.Protocol
_kafkaByteString	Network.Kafka.Protocol
_kafkaTime	Network.Kafka
_keyBytes	Network.Kafka.Protocol
_kString	Network.Kafka.Protocol
_leaderId	Network.Kafka.Protocol
_maxNumOffsets	Network.Kafka
_messageFields	Network.Kafka.Protocol
_messageSetMembers	Network.Kafka.Protocol
_MetadataResponse	Network.Kafka.Protocol
_metadataResponseFields	Network.Kafka.Protocol
_nodeId	Network.Kafka.Protocol
_OffsetCommitResponse	Network.Kafka.Protocol
_OffsetFetchResponse	Network.Kafka.Protocol
_OffsetResponse	Network.Kafka.Protocol
_offsetResponseFields	Network.Kafka.Protocol
_palLeader	Network.Kafka
_palPartition	Network.Kafka
_palTopic	Network.Kafka
_partitionMetadataFields	Network.Kafka.Protocol
_partitionOffsetsFields	Network.Kafka.Protocol
_portInt	Network.Kafka.Protocol
_ProduceResponse	Network.Kafka.Protocol
_produceResponseFields	Network.Kafka.Protocol
_setMessage	Network.Kafka.Protocol
_setOffset	Network.Kafka.Protocol
_stateAddresses	Network.Kafka
_stateBrokers	Network.Kafka
_stateBufferSize	Network.Kafka
_stateConnections	Network.Kafka
_stateCorrelationId	Network.Kafka
_stateName	Network.Kafka
_stateRequestTimeout	Network.Kafka
_stateRequiredAcks	Network.Kafka
_stateTopicMetadata	Network.Kafka
_stateWaitSize	Network.Kafka
_stateWaitTime	Network.Kafka
_tamMessage	Network.Kafka
_tamTopic	Network.Kafka
_tapPartition	Network.Kafka
_tapTopic	Network.Kafka
_timeInt	Network.Kafka.Protocol
_tName	Network.Kafka.Protocol
_topicMetadataFields	Network.Kafka.Protocol
_topicsResponseFields	Network.Kafka.Protocol
_valueBytes	Network.Kafka.Protocol