Contents
Index
milena-0.2.0.0: A Kafka client for Haskell.
Index
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
brokerFields
Network.Kafka.Protocol
brokerHost
Network.Kafka.Protocol
brokerNode
Network.Kafka.Protocol
BrokerNotAvailable
Network.Kafka.Protocol
brokerPartitionInfo
Network.Kafka.Producer
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
ConsumerMetadataReq
Network.Kafka.Protocol
ConsumerMetadataRequest
1 (Type/Class)
Network.Kafka.Protocol
2 (Data Constructor)
Network.Kafka.Protocol
ConsumerMetadataResp
Network.Kafka.Protocol
ConsumerMetadataResponse
1 (Data Constructor)
Network.Kafka.Protocol
2 (Type/Class)
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
defaultState
Network.Kafka
Deserializable
Network.Kafka.Protocol
deserialize
Network.Kafka.Protocol
doRequest
Network.Kafka
doRequest'
Network.Kafka
EarliestTime
Network.Kafka
errorKafka
Network.Kafka.Protocol
ExpectedFetch
Network.Kafka
ExpectedMetadata
Network.Kafka
ExpectedProduce
Network.Kafka
expectResponse
Network.Kafka
fetch
Network.Kafka
fetchMessages
Network.Kafka
FetchReq
Network.Kafka.Protocol
FetchRequest
1 (Type/Class)
Network.Kafka.Protocol
2 (Data Constructor)
Network.Kafka.Protocol
fetchRequest
Network.Kafka
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
findMetadataOrElse
Network.Kafka.Producer
findPartition
Network.Kafka.Protocol
findPartitionMetadata
Network.Kafka.Protocol
getLastOffset
Network.Kafka
getPartition
Network.Kafka.Producer
getResponse
Network.Kafka.Protocol
getResponseMessage
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
KafkaClient
1 (Type/Class)
Network.Kafka
2 (Data Constructor)
Network.Kafka
KafkaClientError
Network.Kafka
kafkaClientHandle
Network.Kafka
KafkaClientId
Network.Kafka
kafkaClientState
Network.Kafka
KafkaDeserializationError
Network.Kafka
KafkaError
Network.Kafka.Protocol
KafkaExpected
Network.Kafka
KafkaExpectedResponse
Network.Kafka
KafkaFailedToFetchMetadata
Network.Kafka
KafkaInvalidBroker
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
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
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
MinBytes
1 (Type/Class)
Network.Kafka.Protocol
2 (Data Constructor)
Network.Kafka.Protocol
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
OffsetsLoadInProgressCode
Network.Kafka.Protocol
ordinaryConsumerId
Network.Kafka
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
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
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
Response
1 (Type/Class)
Network.Kafka.Protocol
2 (Data Constructor)
Network.Kafka.Protocol
responseCorrelationId
Network.Kafka.Protocol
ResponseMessage
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
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
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
withBrokerHandle
Network.Kafka
_brokerFields
Network.Kafka.Protocol
_ConsumerMetadataResponse
Network.Kafka.Protocol
_FetchResponse
Network.Kafka.Protocol
_fetchResponseFields
Network.Kafka.Protocol
_hostKString
Network.Kafka.Protocol
_kafkaByteString
Network.Kafka.Protocol
_kafkaClientHandle
Network.Kafka
_kafkaClientState
Network.Kafka
_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
_responseCorrelationId
Network.Kafka.Protocol
_responseMessage
Network.Kafka.Protocol
_setMessage
Network.Kafka.Protocol
_setOffset
Network.Kafka.Protocol
_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