Safe Haskell	None
Language	Haskell2010

Kafka.Types

Synopsis

Documentation

newtype BrokerId Source #

Constructors

BrokerId Int

Instances

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

newtype PartitionId Source #

Constructors

PartitionId Int

Instances

Enum PartitionId Source #
Methods succ :: PartitionId -> PartitionId # pred :: PartitionId -> PartitionId # toEnum :: Int -> PartitionId # fromEnum :: PartitionId -> Int # enumFrom :: PartitionId -> [PartitionId] # enumFromThen :: PartitionId -> PartitionId -> [PartitionId] # enumFromTo :: PartitionId -> PartitionId -> [PartitionId] # enumFromThenTo :: PartitionId -> PartitionId -> PartitionId -> [PartitionId] #
Eq PartitionId Source #
Methods (==) :: PartitionId -> PartitionId -> Bool # (/=) :: PartitionId -> PartitionId -> Bool #
Ord PartitionId Source #
Methods compare :: PartitionId -> PartitionId -> Ordering # (<) :: PartitionId -> PartitionId -> Bool # (<=) :: PartitionId -> PartitionId -> Bool # (>) :: PartitionId -> PartitionId -> Bool # (>=) :: PartitionId -> PartitionId -> Bool # max :: PartitionId -> PartitionId -> PartitionId # min :: PartitionId -> PartitionId -> PartitionId #
Read PartitionId Source #
Methods readsPrec :: Int -> ReadS PartitionId # readList :: ReadS [PartitionId] # readPrec :: ReadPrec PartitionId # readListPrec :: ReadPrec [PartitionId] #
Show PartitionId Source #
Methods showsPrec :: Int -> PartitionId -> ShowS # show :: PartitionId -> String # showList :: [PartitionId] -> ShowS #

newtype Millis Source #

Constructors

Millis Int64

Instances

Eq Millis Source #
Methods (==) :: Millis -> Millis -> Bool # (/=) :: Millis -> Millis -> Bool #
Num Millis Source #
Methods (+) :: Millis -> Millis -> Millis # (-) :: Millis -> Millis -> Millis # (*) :: Millis -> Millis -> Millis # negate :: Millis -> Millis # abs :: Millis -> Millis # signum :: Millis -> Millis # fromInteger :: Integer -> Millis #
Ord Millis Source #
Methods compare :: Millis -> Millis -> Ordering # (<) :: Millis -> Millis -> Bool # (<=) :: Millis -> Millis -> Bool # (>) :: Millis -> Millis -> Bool # (>=) :: Millis -> Millis -> Bool # max :: Millis -> Millis -> Millis # min :: Millis -> Millis -> Millis #
Read Millis Source #
Methods readsPrec :: Int -> ReadS Millis # readList :: ReadS [Millis] # readPrec :: ReadPrec Millis # readListPrec :: ReadPrec [Millis] #
Show Millis Source #
Methods showsPrec :: Int -> Millis -> ShowS # show :: Millis -> String # showList :: [Millis] -> ShowS #

newtype ClientId Source #

Constructors

ClientId String

Instances

Eq ClientId Source #
Methods (==) :: ClientId -> ClientId -> Bool # (/=) :: ClientId -> ClientId -> Bool #
Ord ClientId Source #
Methods compare :: ClientId -> ClientId -> Ordering # (<) :: ClientId -> ClientId -> Bool # (<=) :: ClientId -> ClientId -> Bool # (>) :: ClientId -> ClientId -> Bool # (>=) :: ClientId -> ClientId -> Bool # max :: ClientId -> ClientId -> ClientId # min :: ClientId -> ClientId -> ClientId #
Show ClientId Source #
Methods showsPrec :: Int -> ClientId -> ShowS # show :: ClientId -> String # showList :: [ClientId] -> ShowS #

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 #