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 |
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 |
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 |
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 |
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 |
produce | 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 |
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 |
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 |
tryKafka | Network.Kafka |
Unknown | Network.Kafka.Protocol |
UnknownTopicOrPartition | 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 |
_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 |
_valueBytes | Network.Kafka.Protocol |