Safe Haskell | None |
---|
- data KafkaConf = KafkaConf RdKafkaConfTPtr
- data KafkaTopicConf = KafkaTopicConf RdKafkaTopicConfTPtr
- data Kafka = Kafka {}
- data KafkaTopic = KafkaTopic RdKafkaTopicTPtr Kafka KafkaTopicConf
- data KafkaOffset
- = KafkaOffsetBeginning
- | KafkaOffsetEnd
- | KafkaOffset Int64
- | KafkaOffsetStored
- data KafkaMessage = KafkaMessage {
- messagePartition :: !Int
- messageOffset :: !Int64
- messagePayload :: !ByteString
- messageKey :: Maybe ByteString
- data KafkaProduceMessage
- = KafkaProduceMessage !ByteString
- | KafkaProduceKeyedMessage !ByteString !ByteString
- data KafkaProducePartition
- data KafkaMetadata = KafkaMetadata {
- brokers :: [KafkaBrokerMetadata]
- topics :: [Either KafkaError KafkaTopicMetadata]
- data KafkaBrokerMetadata = KafkaBrokerMetadata {
- brokerId :: Int
- brokerHost :: String
- brokerPort :: Int
- data KafkaTopicMetadata = KafkaTopicMetadata {
- topicName :: String
- topicPartitions :: [Either KafkaError KafkaPartitionMetadata]
- data KafkaPartitionMetadata = KafkaPartitionMetadata {
- partitionId :: Int
- partitionLeader :: Int
- partitionReplicas :: [Int]
- partitionIsrs :: [Int]
- data KafkaLogLevel
- data KafkaError
- = KafkaError String
- | KafkaInvalidReturnValue
- | KafkaBadSpecification String
- | KafkaResponseError RdKafkaRespErrT
- | KafkaInvalidConfigurationValue String
- | KafkaUnknownConfigurationKey String
- | KakfaBadConfiguration
Documentation
Main pointer to Kafka object, which contains our brokers
data KafkaTopic Source
Main pointer to Kafka topic, which is what we consume from or produce to
data KafkaOffset Source
Starting locations for a consumer
KafkaOffsetBeginning | Start reading from the beginning of the partition |
KafkaOffsetEnd | Start reading from the end |
KafkaOffset Int64 | Start reading from a specific location within the partition |
KafkaOffsetStored | Start reading from the stored offset. See librdkafka's documentation for offset store configuration. |
data KafkaMessage Source
Represents received messages from a Kafka broker (i.e. used in a consumer)
KafkaMessage | |
|
Eq KafkaMessage | |
Read KafkaMessage | |
Show KafkaMessage | |
Typeable KafkaMessage |
data KafkaProduceMessage Source
Represents messages to be enqueued onto a Kafka broker (i.e. used for a producer)
KafkaProduceMessage !ByteString | A message without a key, assigned to |
KafkaProduceKeyedMessage !ByteString !ByteString | A message with a key, assigned to a partition based on the key |
Eq KafkaProduceMessage | |
Show KafkaProduceMessage | |
Typeable KafkaProduceMessage |
data KafkaProducePartition Source
Options for destination partition when enqueuing a message
KafkaSpecifiedPartition !Int | A specific partition in the topic |
KafkaUnassignedPartition | A random partition within the topic |
data KafkaMetadata Source
Metadata for all Kafka brokers
KafkaMetadata | |
|
Eq KafkaMetadata | |
Show KafkaMetadata | |
Typeable KafkaMetadata |
data KafkaBrokerMetadata Source
Metadata for a specific Kafka broker
KafkaBrokerMetadata | |
|
Eq KafkaBrokerMetadata | |
Show KafkaBrokerMetadata | |
Typeable KafkaBrokerMetadata |
data KafkaTopicMetadata Source
Metadata for a specific topic
KafkaTopicMetadata | |
|
Eq KafkaTopicMetadata | |
Show KafkaTopicMetadata | |
Typeable KafkaTopicMetadata |
data KafkaPartitionMetadata Source
Metadata for a specific partition
KafkaPartitionMetadata | |
|
Eq KafkaPartitionMetadata | |
Show KafkaPartitionMetadata | |
Typeable KafkaPartitionMetadata |
data KafkaLogLevel Source
Log levels for the RdKafkaLibrary used in setKafkaLogLevel
KafkaLogEmerg | |
KafkaLogAlert | |
KafkaLogCrit | |
KafkaLogErr | |
KafkaLogWarning | |
KafkaLogNotice | |
KafkaLogInfo | |
KafkaLogDebug |
Enum KafkaLogLevel |
data KafkaError Source
Any Kafka errors
Eq KafkaError | |
Show KafkaError | |
Typeable KafkaError | |
Exception KafkaError |