Safe Haskell | None |
---|---|
Language | Haskell2010 |
Kafka.Types
- newtype BrokerId = BrokerId {
- unBrokerId :: Int
- newtype PartitionId = PartitionId {
- unPartitionId :: Int
- newtype Millis = Millis {}
- newtype ClientId = ClientId {
- unClientId :: String
- newtype TopicName = TopicName {}
- newtype BrokerAddress = BrokerAddress {}
- newtype Timeout = Timeout {}
- data KafkaLogLevel
- data KafkaError
- data KafkaDebug
- kafkaDebugToString :: KafkaDebug -> String
- data KafkaCompressionCodec
- = NoCompression
- | Gzip
- | Snappy
- | Lz4
- kafkaCompressionCodecToString :: KafkaCompressionCodec -> String
Documentation
Constructors
BrokerId | |
Fields
|
Constructors
ClientId | |
Fields
|
Topic name to be consumed
Wildcard (regex) topics are supported by the librdkafka assignor:
any topic name in the topics list that is prefixed with ^
will
be regex-matched to the full list of topics in the cluster and matching
topics will be added to the subscription list.
Constructors
TopicName | a simple topic name or a regex if started with |
Fields |
newtype BrokerAddress Source #
Kafka broker address string (e.g. broker1:9092
)
Constructors
BrokerAddress | |
Fields |
Instances
Timeout in milliseconds
data KafkaLogLevel Source #
Log levels for librdkafka.
Constructors
KafkaLogEmerg | |
KafkaLogAlert | |
KafkaLogCrit | |
KafkaLogErr | |
KafkaLogWarning | |
KafkaLogNotice | |
KafkaLogInfo | |
KafkaLogDebug |
Instances
data KafkaError Source #
Any Kafka errors
Constructors
Instances
data KafkaDebug Source #
Constructors
DebugGeneric | |
DebugBroker | |
DebugTopic | |
DebugMetadata | |
DebugQueue | |
DebugMsg | |
DebugProtocol | |
DebugCgrp | |
DebugSecurity | |
DebugFetch | |
DebugFeature | |
DebugAll |
Instances