Safe Haskell	Safe
Language	Haskell2010

Kafka.Types

Synopsis

Documentation

newtype TopicName Source #

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 String

a simple topic name or a regex if started with ^

Instances

Eq TopicName Source #
Methods (==) :: TopicName -> TopicName -> Bool # (/=) :: TopicName -> TopicName -> Bool #
Ord TopicName Source #
Methods compare :: TopicName -> TopicName -> Ordering # (<) :: TopicName -> TopicName -> Bool # (<=) :: TopicName -> TopicName -> Bool # (>) :: TopicName -> TopicName -> Bool # (>=) :: TopicName -> TopicName -> Bool # max :: TopicName -> TopicName -> TopicName # min :: TopicName -> TopicName -> TopicName #
Read TopicName Source #
Methods readsPrec :: Int -> ReadS TopicName # readList :: ReadS [TopicName] # readPrec :: ReadPrec TopicName # readListPrec :: ReadPrec [TopicName] #
Show TopicName Source #
Methods showsPrec :: Int -> TopicName -> ShowS # show :: TopicName -> String # showList :: [TopicName] -> ShowS #

newtype BrokerAddress Source #

Kafka broker address string (e.g. broker1:9092)

Constructors

BrokerAddress String

Instances

Eq BrokerAddress Source #
Methods (==) :: BrokerAddress -> BrokerAddress -> Bool # (/=) :: BrokerAddress -> BrokerAddress -> Bool #
Show BrokerAddress Source #
Methods showsPrec :: Int -> BrokerAddress -> ShowS # show :: BrokerAddress -> String # showList :: [BrokerAddress] -> ShowS #

newtype Timeout Source #

Timeout in milliseconds

Constructors

Timeout Int

Instances

Eq Timeout Source #
Methods (==) :: Timeout -> Timeout -> Bool # (/=) :: Timeout -> Timeout -> Bool #
Read Timeout Source #
Methods readsPrec :: Int -> ReadS Timeout # readList :: ReadS [Timeout] # readPrec :: ReadPrec Timeout # readListPrec :: ReadPrec [Timeout] #
Show Timeout Source #
Methods showsPrec :: Int -> Timeout -> ShowS # show :: Timeout -> String # showList :: [Timeout] -> ShowS #

data KafkaLogLevel Source #

Log levels for librdkafka.

Constructors

KafkaLogEmerg
KafkaLogAlert
KafkaLogCrit
KafkaLogErr
KafkaLogWarning
KafkaLogNotice
KafkaLogInfo
KafkaLogDebug

Instances

Enum KafkaLogLevel Source #
Methods succ :: KafkaLogLevel -> KafkaLogLevel # pred :: KafkaLogLevel -> KafkaLogLevel # toEnum :: Int -> KafkaLogLevel # fromEnum :: KafkaLogLevel -> Int # enumFrom :: KafkaLogLevel -> [KafkaLogLevel] # enumFromThen :: KafkaLogLevel -> KafkaLogLevel -> [KafkaLogLevel] # enumFromTo :: KafkaLogLevel -> KafkaLogLevel -> [KafkaLogLevel] # enumFromThenTo :: KafkaLogLevel -> KafkaLogLevel -> KafkaLogLevel -> [KafkaLogLevel] #
Eq KafkaLogLevel Source #
Methods (==) :: KafkaLogLevel -> KafkaLogLevel -> Bool # (/=) :: KafkaLogLevel -> KafkaLogLevel -> Bool #
Show KafkaLogLevel Source #
Methods showsPrec :: Int -> KafkaLogLevel -> ShowS # show :: KafkaLogLevel -> String # showList :: [KafkaLogLevel] -> ShowS #

data KafkaError Source #

Any Kafka errors

Constructors

KafkaError String
KafkaInvalidReturnValue
KafkaBadSpecification String
KafkaResponseError RdKafkaRespErrT
KafkaInvalidConfigurationValue String
KafkaUnknownConfigurationKey String
KakfaBadConfiguration

Instances

Eq KafkaError Source #
Methods (==) :: KafkaError -> KafkaError -> Bool # (/=) :: KafkaError -> KafkaError -> Bool #
Show KafkaError Source #
Methods showsPrec :: Int -> KafkaError -> ShowS # show :: KafkaError -> String # showList :: [KafkaError] -> ShowS #
Exception KafkaError Source #
Methods toException :: KafkaError -> SomeException # fromException :: SomeException -> Maybe KafkaError # displayException :: KafkaError -> String #

data KafkaDebug Source #

Constructors

DebugGeneric
DebugBroker
DebugTopic
DebugMetadata
DebugQueue
DebugMsg
DebugProtocol
DebugCgrp
DebugSecurity
DebugFetch
DebugFeature
DebugAll

Instances

Eq KafkaDebug Source #
Methods (==) :: KafkaDebug -> KafkaDebug -> Bool # (/=) :: KafkaDebug -> KafkaDebug -> Bool #
Show KafkaDebug Source #
Methods showsPrec :: Int -> KafkaDebug -> ShowS # show :: KafkaDebug -> String # showList :: [KafkaDebug] -> ShowS #

kafkaDebugToString :: KafkaDebug -> String Source #

data KafkaCompressionCodec Source #

Constructors

NoCompression
Gzip
Snappy
Lz4

Instances

Eq KafkaCompressionCodec Source #
Methods (==) :: KafkaCompressionCodec -> KafkaCompressionCodec -> Bool # (/=) :: KafkaCompressionCodec -> KafkaCompressionCodec -> Bool #
Show KafkaCompressionCodec Source #
Methods showsPrec :: Int -> KafkaCompressionCodec -> ShowS # show :: KafkaCompressionCodec -> String # showList :: [KafkaCompressionCodec] -> ShowS #

kafkaCompressionCodecToString :: KafkaCompressionCodec -> String Source #