Safe Haskell	None
Language	Haskell2010

Kafka.Types

Description

Module holding types shared by consumer and producer modules.

Synopsis

newtype BrokerId = BrokerId {
- unBrokerId :: Int
}
newtype PartitionId = PartitionId {
- unPartitionId :: Int
}
newtype Millis = Millis {
- unMillis :: Int64
}
newtype ClientId = ClientId {
- unClientId :: Text
}
newtype BatchSize = BatchSize {
- unBatchSize :: Int
}
newtype TopicName = TopicName {
- unTopicName :: Text
}
newtype BrokerAddress = BrokerAddress {
- unBrokerAddress :: Text
}
newtype Timeout = Timeout {
- unTimeout :: Int
}
data KafkaLogLevel
- = KafkaLogEmerg
- | KafkaLogAlert
- | KafkaLogCrit
- | KafkaLogErr
- | KafkaLogWarning
- | KafkaLogNotice
- | KafkaLogInfo
- | KafkaLogDebug
data KafkaError
data KafkaDebug
- = DebugGeneric
- | DebugBroker
- | DebugTopic
- | DebugMetadata
- | DebugQueue
- | DebugMsg
- | DebugProtocol
- | DebugCgrp
- | DebugSecurity
- | DebugFetch
- | DebugFeature
- | DebugAll
data KafkaCompressionCodec
- = NoCompression
- | Gzip
- | Snappy
- | Lz4
- | Zstd
data TopicType
- = User
- | System
data Headers
headersFromList :: [(ByteString, ByteString)] -> Headers
headersToList :: Headers -> [(ByteString, ByteString)]
topicType :: TopicName -> TopicType
kafkaDebugToText :: KafkaDebug -> Text
kafkaCompressionCodecToText :: KafkaCompressionCodec -> Text

Documentation

newtype BrokerId Source #

Kafka broker ID

Constructors

BrokerId
Fields unBrokerId :: Int

Instances

Instances details

Generic BrokerId Source #

Instance details

Defined in Kafka.Types

Associated Types

type Rep BrokerId
Instance details Defined in Kafka.Types type Rep BrokerId = D1 ('MetaData "BrokerId" "Kafka.Types" "hw-kafka-client-5.3.0-8OZSN6XHxJUEBGq88IRkoi" 'True) (C1 ('MetaCons "BrokerId" 'PrefixI 'True) (S1 ('MetaSel ('Just "unBrokerId") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int)))

Methods

from :: BrokerId -> Rep BrokerId x #

to :: Rep BrokerId x -> BrokerId #

Read BrokerId Source #

Instance details

Defined in Kafka.Types

Methods

readsPrec :: Int -> ReadS BrokerId #

readList :: ReadS [BrokerId] #

readPrec :: ReadPrec BrokerId #

readListPrec :: ReadPrec [BrokerId] #

Show BrokerId Source #

Instance details

Defined in Kafka.Types

Methods

showsPrec :: Int -> BrokerId -> ShowS #

show :: BrokerId -> String #

showList :: [BrokerId] -> ShowS #

Eq BrokerId Source #

Instance details

Defined in Kafka.Types

Methods

(==) :: BrokerId -> BrokerId -> Bool #

(/=) :: BrokerId -> BrokerId -> Bool #

Ord BrokerId Source #

Instance details

Defined in Kafka.Types

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 #

type Rep BrokerId Source #

Instance details

Defined in Kafka.Types

type Rep BrokerId = D1 ('MetaData "BrokerId" "Kafka.Types" "hw-kafka-client-5.3.0-8OZSN6XHxJUEBGq88IRkoi" 'True) (C1 ('MetaCons "BrokerId" 'PrefixI 'True) (S1 ('MetaSel ('Just "unBrokerId") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int)))

newtype PartitionId Source #

Topic partition ID

Constructors

PartitionId
Fields unPartitionId :: Int

Instances

Instances details

Enum PartitionId Source #

Instance details

Defined in Kafka.Types

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] #

Generic PartitionId Source #

Instance details

Defined in Kafka.Types

Associated Types

type Rep PartitionId
Instance details Defined in Kafka.Types type Rep PartitionId = D1 ('MetaData "PartitionId" "Kafka.Types" "hw-kafka-client-5.3.0-8OZSN6XHxJUEBGq88IRkoi" 'True) (C1 ('MetaCons "PartitionId" 'PrefixI 'True) (S1 ('MetaSel ('Just "unPartitionId") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int)))

Methods

from :: PartitionId -> Rep PartitionId x #

to :: Rep PartitionId x -> PartitionId #

Read PartitionId Source #

Instance details

Defined in Kafka.Types

Methods

readsPrec :: Int -> ReadS PartitionId #

readList :: ReadS [PartitionId] #

readPrec :: ReadPrec PartitionId #

readListPrec :: ReadPrec [PartitionId] #

Show PartitionId Source #

Instance details

Defined in Kafka.Types

Methods

showsPrec :: Int -> PartitionId -> ShowS #

show :: PartitionId -> String #

showList :: [PartitionId] -> ShowS #

Eq PartitionId Source #

Instance details

Defined in Kafka.Types

Methods

(==) :: PartitionId -> PartitionId -> Bool #

(/=) :: PartitionId -> PartitionId -> Bool #

Ord PartitionId Source #

Instance details

Defined in Kafka.Types

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 #

type Rep PartitionId Source #

Instance details

Defined in Kafka.Types

type Rep PartitionId = D1 ('MetaData "PartitionId" "Kafka.Types" "hw-kafka-client-5.3.0-8OZSN6XHxJUEBGq88IRkoi" 'True) (C1 ('MetaCons "PartitionId" 'PrefixI 'True) (S1 ('MetaSel ('Just "unPartitionId") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int)))

newtype Millis Source #

A number of milliseconds, used to represent durations and timestamps

Constructors

Millis
Fields unMillis :: Int64

Instances

Instances details

Generic Millis Source #

Instance details

Defined in Kafka.Types

Associated Types

type Rep Millis
Instance details Defined in Kafka.Types type Rep Millis = D1 ('MetaData "Millis" "Kafka.Types" "hw-kafka-client-5.3.0-8OZSN6XHxJUEBGq88IRkoi" 'True) (C1 ('MetaCons "Millis" 'PrefixI 'True) (S1 ('MetaSel ('Just "unMillis") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int64)))

Methods

from :: Millis -> Rep Millis x #

to :: Rep Millis x -> Millis #

Num Millis Source #

Instance details

Defined in Kafka.Types

Methods

(+) :: Millis -> Millis -> Millis #

(-) :: Millis -> Millis -> Millis #

(*) :: Millis -> Millis -> Millis #

negate :: Millis -> Millis #

abs :: Millis -> Millis #

signum :: Millis -> Millis #

fromInteger :: Integer -> Millis #

Read Millis Source #

Instance details

Defined in Kafka.Types

Methods

readsPrec :: Int -> ReadS Millis #

readList :: ReadS [Millis] #

readPrec :: ReadPrec Millis #

readListPrec :: ReadPrec [Millis] #

Show Millis Source #

Instance details

Defined in Kafka.Types

Methods

showsPrec :: Int -> Millis -> ShowS #

show :: Millis -> String #

showList :: [Millis] -> ShowS #

Eq Millis Source #

Instance details

Defined in Kafka.Types

Methods

(==) :: Millis -> Millis -> Bool #

(/=) :: Millis -> Millis -> Bool #

Ord Millis Source #

Instance details

Defined in Kafka.Types

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 #

type Rep Millis Source #

Instance details

Defined in Kafka.Types

type Rep Millis = D1 ('MetaData "Millis" "Kafka.Types" "hw-kafka-client-5.3.0-8OZSN6XHxJUEBGq88IRkoi" 'True) (C1 ('MetaCons "Millis" 'PrefixI 'True) (S1 ('MetaSel ('Just "unMillis") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int64)))

newtype ClientId Source #

Client ID used by Kafka to better track requests

See Kafka documentation on client ID

Constructors

ClientId
Fields unClientId :: Text

Instances

Instances details

IsString ClientId Source #

Instance details

Defined in Kafka.Types

Methods

fromString :: String -> ClientId #

Generic ClientId Source #

Instance details

Defined in Kafka.Types

Associated Types

type Rep ClientId
Instance details Defined in Kafka.Types type Rep ClientId = D1 ('MetaData "ClientId" "Kafka.Types" "hw-kafka-client-5.3.0-8OZSN6XHxJUEBGq88IRkoi" 'True) (C1 ('MetaCons "ClientId" 'PrefixI 'True) (S1 ('MetaSel ('Just "unClientId") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Text)))

Methods

from :: ClientId -> Rep ClientId x #

to :: Rep ClientId x -> ClientId #

Show ClientId Source #

Instance details

Defined in Kafka.Types

Methods

showsPrec :: Int -> ClientId -> ShowS #

show :: ClientId -> String #

showList :: [ClientId] -> ShowS #

Eq ClientId Source #

Instance details

Defined in Kafka.Types

Methods

(==) :: ClientId -> ClientId -> Bool #

(/=) :: ClientId -> ClientId -> Bool #

Ord ClientId Source #

Instance details

Defined in Kafka.Types

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 #

type Rep ClientId Source #

Instance details

Defined in Kafka.Types

type Rep ClientId = D1 ('MetaData "ClientId" "Kafka.Types" "hw-kafka-client-5.3.0-8OZSN6XHxJUEBGq88IRkoi" 'True) (C1 ('MetaCons "ClientId" 'PrefixI 'True) (S1 ('MetaSel ('Just "unClientId") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Text)))

newtype BatchSize Source #

Batch size used for polling

Constructors

BatchSize
Fields unBatchSize :: Int

Instances

Instances details

Generic BatchSize Source #

Instance details

Defined in Kafka.Types

Associated Types

type Rep BatchSize
Instance details Defined in Kafka.Types type Rep BatchSize = D1 ('MetaData "BatchSize" "Kafka.Types" "hw-kafka-client-5.3.0-8OZSN6XHxJUEBGq88IRkoi" 'True) (C1 ('MetaCons "BatchSize" 'PrefixI 'True) (S1 ('MetaSel ('Just "unBatchSize") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int)))

Methods

from :: BatchSize -> Rep BatchSize x #

to :: Rep BatchSize x -> BatchSize #

Num BatchSize Source #

Instance details

Defined in Kafka.Types

Methods

(+) :: BatchSize -> BatchSize -> BatchSize #

(-) :: BatchSize -> BatchSize -> BatchSize #

(*) :: BatchSize -> BatchSize -> BatchSize #

negate :: BatchSize -> BatchSize #

abs :: BatchSize -> BatchSize #

signum :: BatchSize -> BatchSize #

fromInteger :: Integer -> BatchSize #

Read BatchSize Source #

Instance details

Defined in Kafka.Types

Methods

readsPrec :: Int -> ReadS BatchSize #

readList :: ReadS [BatchSize] #

readPrec :: ReadPrec BatchSize #

readListPrec :: ReadPrec [BatchSize] #

Show BatchSize Source #

Instance details

Defined in Kafka.Types

Methods

showsPrec :: Int -> BatchSize -> ShowS #

show :: BatchSize -> String #

showList :: [BatchSize] -> ShowS #

Eq BatchSize Source #

Instance details

Defined in Kafka.Types

Methods

(==) :: BatchSize -> BatchSize -> Bool #

(/=) :: BatchSize -> BatchSize -> Bool #

Ord BatchSize Source #

Instance details

Defined in Kafka.Types

Methods

compare :: BatchSize -> BatchSize -> Ordering #

(<) :: BatchSize -> BatchSize -> Bool #

(<=) :: BatchSize -> BatchSize -> Bool #

(>) :: BatchSize -> BatchSize -> Bool #

(>=) :: BatchSize -> BatchSize -> Bool #

max :: BatchSize -> BatchSize -> BatchSize #

min :: BatchSize -> BatchSize -> BatchSize #

type Rep BatchSize Source #

Instance details

Defined in Kafka.Types

type Rep BatchSize = D1 ('MetaData "BatchSize" "Kafka.Types" "hw-kafka-client-5.3.0-8OZSN6XHxJUEBGq88IRkoi" 'True) (C1 ('MetaCons "BatchSize" 'PrefixI 'True) (S1 ('MetaSel ('Just "unBatchSize") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int)))

newtype TopicName Source #

Topic name to consume/produce messages

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
Fields unTopicName :: Text a simple topic name or a regex if started with `^`

Instances

Instances details

IsString TopicName Source #

Instance details

Defined in Kafka.Types

Methods

fromString :: String -> TopicName #

Generic TopicName Source #

Instance details

Defined in Kafka.Types

Associated Types

type Rep TopicName
Instance details Defined in Kafka.Types type Rep TopicName = D1 ('MetaData "TopicName" "Kafka.Types" "hw-kafka-client-5.3.0-8OZSN6XHxJUEBGq88IRkoi" 'True) (C1 ('MetaCons "TopicName" 'PrefixI 'True) (S1 ('MetaSel ('Just "unTopicName") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Text)))

Methods

from :: TopicName -> Rep TopicName x #

to :: Rep TopicName x -> TopicName #

Read TopicName Source #

Instance details

Defined in Kafka.Types

Methods

readsPrec :: Int -> ReadS TopicName #

readList :: ReadS [TopicName] #

readPrec :: ReadPrec TopicName #

readListPrec :: ReadPrec [TopicName] #

Show TopicName Source #

Instance details

Defined in Kafka.Types

Methods

showsPrec :: Int -> TopicName -> ShowS #

show :: TopicName -> String #

showList :: [TopicName] -> ShowS #

Eq TopicName Source #

Instance details

Defined in Kafka.Types

Methods

(==) :: TopicName -> TopicName -> Bool #

(/=) :: TopicName -> TopicName -> Bool #

Ord TopicName Source #

Instance details

Defined in Kafka.Types

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 #

type Rep TopicName Source #

Instance details

Defined in Kafka.Types

type Rep TopicName = D1 ('MetaData "TopicName" "Kafka.Types" "hw-kafka-client-5.3.0-8OZSN6XHxJUEBGq88IRkoi" 'True) (C1 ('MetaCons "TopicName" 'PrefixI 'True) (S1 ('MetaSel ('Just "unTopicName") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Text)))

newtype BrokerAddress Source #

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

Constructors

BrokerAddress
Fields unBrokerAddress :: Text

Instances

Instances details

IsString BrokerAddress Source #

Instance details

Defined in Kafka.Types

Methods

fromString :: String -> BrokerAddress #

Generic BrokerAddress Source #

Instance details

Defined in Kafka.Types

Associated Types

type Rep BrokerAddress
Instance details Defined in Kafka.Types type Rep BrokerAddress = D1 ('MetaData "BrokerAddress" "Kafka.Types" "hw-kafka-client-5.3.0-8OZSN6XHxJUEBGq88IRkoi" 'True) (C1 ('MetaCons "BrokerAddress" 'PrefixI 'True) (S1 ('MetaSel ('Just "unBrokerAddress") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Text)))

Methods

from :: BrokerAddress -> Rep BrokerAddress x #

to :: Rep BrokerAddress x -> BrokerAddress #

Show BrokerAddress Source #

Instance details

Defined in Kafka.Types

Methods

showsPrec :: Int -> BrokerAddress -> ShowS #

show :: BrokerAddress -> String #

showList :: [BrokerAddress] -> ShowS #

Eq BrokerAddress Source #

Instance details

Defined in Kafka.Types

Methods

(==) :: BrokerAddress -> BrokerAddress -> Bool #

(/=) :: BrokerAddress -> BrokerAddress -> Bool #

type Rep BrokerAddress Source #

Instance details

Defined in Kafka.Types

type Rep BrokerAddress = D1 ('MetaData "BrokerAddress" "Kafka.Types" "hw-kafka-client-5.3.0-8OZSN6XHxJUEBGq88IRkoi" 'True) (C1 ('MetaCons "BrokerAddress" 'PrefixI 'True) (S1 ('MetaSel ('Just "unBrokerAddress") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Text)))

newtype Timeout Source #

Timeout in milliseconds

Constructors

Timeout
Fields unTimeout :: Int

Instances

Instances details

Generic Timeout Source #

Instance details

Defined in Kafka.Types

Associated Types

type Rep Timeout
Instance details Defined in Kafka.Types type Rep Timeout = D1 ('MetaData "Timeout" "Kafka.Types" "hw-kafka-client-5.3.0-8OZSN6XHxJUEBGq88IRkoi" 'True) (C1 ('MetaCons "Timeout" 'PrefixI 'True) (S1 ('MetaSel ('Just "unTimeout") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int)))

Methods

from :: Timeout -> Rep Timeout x #

to :: Rep Timeout x -> Timeout #

Read Timeout Source #

Instance details

Defined in Kafka.Types

Methods

readsPrec :: Int -> ReadS Timeout #

readList :: ReadS [Timeout] #

readPrec :: ReadPrec Timeout #

readListPrec :: ReadPrec [Timeout] #

Show Timeout Source #

Instance details

Defined in Kafka.Types

Methods

showsPrec :: Int -> Timeout -> ShowS #

show :: Timeout -> String #

showList :: [Timeout] -> ShowS #

Eq Timeout Source #

Instance details

Defined in Kafka.Types

Methods

(==) :: Timeout -> Timeout -> Bool #

(/=) :: Timeout -> Timeout -> Bool #

type Rep Timeout Source #

Instance details

Defined in Kafka.Types

type Rep Timeout = D1 ('MetaData "Timeout" "Kafka.Types" "hw-kafka-client-5.3.0-8OZSN6XHxJUEBGq88IRkoi" 'True) (C1 ('MetaCons "Timeout" 'PrefixI 'True) (S1 ('MetaSel ('Just "unTimeout") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int)))

data KafkaLogLevel Source #

Log levels for librdkafka.

Constructors

KafkaLogEmerg
KafkaLogAlert
KafkaLogCrit
KafkaLogErr
KafkaLogWarning
KafkaLogNotice
KafkaLogInfo
KafkaLogDebug

Instances

Instances details

Enum KafkaLogLevel Source #
Instance details Defined in Kafka.Types 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] #
Show KafkaLogLevel Source #
Instance details Defined in Kafka.Types Methods showsPrec :: Int -> KafkaLogLevel -> ShowS # show :: KafkaLogLevel -> String # showList :: [KafkaLogLevel] -> ShowS #
Eq KafkaLogLevel Source #
Instance details Defined in Kafka.Types Methods (==) :: KafkaLogLevel -> KafkaLogLevel -> Bool # (/=) :: KafkaLogLevel -> KafkaLogLevel -> Bool #

data KafkaError Source #

All possible Kafka errors

Constructors

KafkaError Text
KafkaInvalidReturnValue
KafkaBadSpecification Text
KafkaResponseError RdKafkaRespErrT
KafkaInvalidConfigurationValue Text
KafkaUnknownConfigurationKey Text
KafkaBadConfiguration

Instances

Instances details

Exception KafkaError Source #

Instance details

Defined in Kafka.Types

Methods

toException :: KafkaError -> SomeException #

fromException :: SomeException -> Maybe KafkaError #

displayException :: KafkaError -> String #

backtraceDesired :: KafkaError -> Bool #

Generic KafkaError Source #

Instance details

Defined in Kafka.Types

Associated Types

type Rep KafkaError

Instance details

Defined in Kafka.Types

type Rep KafkaError = D1 ('MetaData "KafkaError" "Kafka.Types" "hw-kafka-client-5.3.0-8OZSN6XHxJUEBGq88IRkoi" 'False) ((C1 ('MetaCons "KafkaError" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Text)) :+: (C1 ('MetaCons "KafkaInvalidReturnValue" 'PrefixI 'False) (U1 :: Type -> Type) :+: C1 ('MetaCons "KafkaBadSpecification" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Text)))) :+: ((C1 ('MetaCons "KafkaResponseError" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 RdKafkaRespErrT)) :+: C1 ('MetaCons "KafkaInvalidConfigurationValue" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Text))) :+: (C1 ('MetaCons "KafkaUnknownConfigurationKey" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Text)) :+: C1 ('MetaCons "KafkaBadConfiguration" 'PrefixI 'False) (U1 :: Type -> Type))))

Methods

from :: KafkaError -> Rep KafkaError x #

to :: Rep KafkaError x -> KafkaError #

Show KafkaError Source #

Instance details

Defined in Kafka.Types

Methods

showsPrec :: Int -> KafkaError -> ShowS #

show :: KafkaError -> String #

showList :: [KafkaError] -> ShowS #

Eq KafkaError Source #

Instance details

Defined in Kafka.Types

Methods

(==) :: KafkaError -> KafkaError -> Bool #

(/=) :: KafkaError -> KafkaError -> Bool #

type Rep KafkaError Source #

Instance details

Defined in Kafka.Types

type Rep KafkaError = D1 ('MetaData "KafkaError" "Kafka.Types" "hw-kafka-client-5.3.0-8OZSN6XHxJUEBGq88IRkoi" 'False) ((C1 ('MetaCons "KafkaError" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Text)) :+: (C1 ('MetaCons "KafkaInvalidReturnValue" 'PrefixI 'False) (U1 :: Type -> Type) :+: C1 ('MetaCons "KafkaBadSpecification" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Text)))) :+: ((C1 ('MetaCons "KafkaResponseError" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 RdKafkaRespErrT)) :+: C1 ('MetaCons "KafkaInvalidConfigurationValue" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Text))) :+: (C1 ('MetaCons "KafkaUnknownConfigurationKey" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Text)) :+: C1 ('MetaCons "KafkaBadConfiguration" 'PrefixI 'False) (U1 :: Type -> Type))))

data KafkaDebug Source #

Available librdkafka debug contexts

Constructors

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

Instances

Instances details

Generic KafkaDebug Source #

Instance details

Defined in Kafka.Types

Associated Types

type Rep KafkaDebug

Instance details

Defined in Kafka.Types

type Rep KafkaDebug = D1 ('MetaData "KafkaDebug" "Kafka.Types" "hw-kafka-client-5.3.0-8OZSN6XHxJUEBGq88IRkoi" 'False) (((C1 ('MetaCons "DebugGeneric" 'PrefixI 'False) (U1 :: Type -> Type) :+: (C1 ('MetaCons "DebugBroker" 'PrefixI 'False) (U1 :: Type -> Type) :+: C1 ('MetaCons "DebugTopic" 'PrefixI 'False) (U1 :: Type -> Type))) :+: (C1 ('MetaCons "DebugMetadata" 'PrefixI 'False) (U1 :: Type -> Type) :+: (C1 ('MetaCons "DebugQueue" 'PrefixI 'False) (U1 :: Type -> Type) :+: C1 ('MetaCons "DebugMsg" 'PrefixI 'False) (U1 :: Type -> Type)))) :+: ((C1 ('MetaCons "DebugProtocol" 'PrefixI 'False) (U1 :: Type -> Type) :+: (C1 ('MetaCons "DebugCgrp" 'PrefixI 'False) (U1 :: Type -> Type) :+: C1 ('MetaCons "DebugSecurity" 'PrefixI 'False) (U1 :: Type -> Type))) :+: (C1 ('MetaCons "DebugFetch" 'PrefixI 'False) (U1 :: Type -> Type) :+: (C1 ('MetaCons "DebugFeature" 'PrefixI 'False) (U1 :: Type -> Type) :+: C1 ('MetaCons "DebugAll" 'PrefixI 'False) (U1 :: Type -> Type)))))

Methods

from :: KafkaDebug -> Rep KafkaDebug x #

to :: Rep KafkaDebug x -> KafkaDebug #

Show KafkaDebug Source #

Instance details

Defined in Kafka.Types

Methods

showsPrec :: Int -> KafkaDebug -> ShowS #

show :: KafkaDebug -> String #

showList :: [KafkaDebug] -> ShowS #

Eq KafkaDebug Source #

Instance details

Defined in Kafka.Types

Methods

(==) :: KafkaDebug -> KafkaDebug -> Bool #

(/=) :: KafkaDebug -> KafkaDebug -> Bool #

type Rep KafkaDebug Source #

Instance details

Defined in Kafka.Types

type Rep KafkaDebug = D1 ('MetaData "KafkaDebug" "Kafka.Types" "hw-kafka-client-5.3.0-8OZSN6XHxJUEBGq88IRkoi" 'False) (((C1 ('MetaCons "DebugGeneric" 'PrefixI 'False) (U1 :: Type -> Type) :+: (C1 ('MetaCons "DebugBroker" 'PrefixI 'False) (U1 :: Type -> Type) :+: C1 ('MetaCons "DebugTopic" 'PrefixI 'False) (U1 :: Type -> Type))) :+: (C1 ('MetaCons "DebugMetadata" 'PrefixI 'False) (U1 :: Type -> Type) :+: (C1 ('MetaCons "DebugQueue" 'PrefixI 'False) (U1 :: Type -> Type) :+: C1 ('MetaCons "DebugMsg" 'PrefixI 'False) (U1 :: Type -> Type)))) :+: ((C1 ('MetaCons "DebugProtocol" 'PrefixI 'False) (U1 :: Type -> Type) :+: (C1 ('MetaCons "DebugCgrp" 'PrefixI 'False) (U1 :: Type -> Type) :+: C1 ('MetaCons "DebugSecurity" 'PrefixI 'False) (U1 :: Type -> Type))) :+: (C1 ('MetaCons "DebugFetch" 'PrefixI 'False) (U1 :: Type -> Type) :+: (C1 ('MetaCons "DebugFeature" 'PrefixI 'False) (U1 :: Type -> Type) :+: C1 ('MetaCons "DebugAll" 'PrefixI 'False) (U1 :: Type -> Type)))))

data KafkaCompressionCodec Source #

Compression codec used by a topic

See Kafka documentation on compression codecs

Constructors

NoCompression
Gzip
Snappy
Lz4
Zstd

Instances

Instances details

Generic KafkaCompressionCodec Source #

Instance details

Defined in Kafka.Types

Associated Types

type Rep KafkaCompressionCodec

Instance details

Defined in Kafka.Types

type Rep KafkaCompressionCodec = D1 ('MetaData "KafkaCompressionCodec" "Kafka.Types" "hw-kafka-client-5.3.0-8OZSN6XHxJUEBGq88IRkoi" 'False) ((C1 ('MetaCons "NoCompression" 'PrefixI 'False) (U1 :: Type -> Type) :+: C1 ('MetaCons "Gzip" 'PrefixI 'False) (U1 :: Type -> Type)) :+: (C1 ('MetaCons "Snappy" 'PrefixI 'False) (U1 :: Type -> Type) :+: (C1 ('MetaCons "Lz4" 'PrefixI 'False) (U1 :: Type -> Type) :+: C1 ('MetaCons "Zstd" 'PrefixI 'False) (U1 :: Type -> Type))))

Methods

from :: KafkaCompressionCodec -> Rep KafkaCompressionCodec x #

to :: Rep KafkaCompressionCodec x -> KafkaCompressionCodec #

Show KafkaCompressionCodec Source #

Instance details

Defined in Kafka.Types

Methods

showsPrec :: Int -> KafkaCompressionCodec -> ShowS #

show :: KafkaCompressionCodec -> String #

showList :: [KafkaCompressionCodec] -> ShowS #

Eq KafkaCompressionCodec Source #

Instance details

Defined in Kafka.Types

Methods

(==) :: KafkaCompressionCodec -> KafkaCompressionCodec -> Bool #

(/=) :: KafkaCompressionCodec -> KafkaCompressionCodec -> Bool #

type Rep KafkaCompressionCodec Source #

Instance details

Defined in Kafka.Types

type Rep KafkaCompressionCodec = D1 ('MetaData "KafkaCompressionCodec" "Kafka.Types" "hw-kafka-client-5.3.0-8OZSN6XHxJUEBGq88IRkoi" 'False) ((C1 ('MetaCons "NoCompression" 'PrefixI 'False) (U1 :: Type -> Type) :+: C1 ('MetaCons "Gzip" 'PrefixI 'False) (U1 :: Type -> Type)) :+: (C1 ('MetaCons "Snappy" 'PrefixI 'False) (U1 :: Type -> Type) :+: (C1 ('MetaCons "Lz4" 'PrefixI 'False) (U1 :: Type -> Type) :+: C1 ('MetaCons "Zstd" 'PrefixI 'False) (U1 :: Type -> Type))))

data TopicType Source #

Whether the topic is created by a user or by the system

Constructors

User	Normal topics that are created by user.
System	Topics starting with a double underscore "__" (`__consumer_offsets`, `__confluent.support.metrics`, etc.) are considered "system" topics

Instances

Instances details

Generic TopicType Source #

Instance details

Defined in Kafka.Types

Associated Types

type Rep TopicType
Instance details Defined in Kafka.Types type Rep TopicType = D1 ('MetaData "TopicType" "Kafka.Types" "hw-kafka-client-5.3.0-8OZSN6XHxJUEBGq88IRkoi" 'False) (C1 ('MetaCons "User" 'PrefixI 'False) (U1 :: Type -> Type) :+: C1 ('MetaCons "System" 'PrefixI 'False) (U1 :: Type -> Type))

Methods

from :: TopicType -> Rep TopicType x #

to :: Rep TopicType x -> TopicType #

Read TopicType Source #

Instance details

Defined in Kafka.Types

Methods

readsPrec :: Int -> ReadS TopicType #

readList :: ReadS [TopicType] #

readPrec :: ReadPrec TopicType #

readListPrec :: ReadPrec [TopicType] #

Show TopicType Source #

Instance details

Defined in Kafka.Types

Methods

showsPrec :: Int -> TopicType -> ShowS #

show :: TopicType -> String #

showList :: [TopicType] -> ShowS #

Eq TopicType Source #

Instance details

Defined in Kafka.Types

Methods

(==) :: TopicType -> TopicType -> Bool #

(/=) :: TopicType -> TopicType -> Bool #

Ord TopicType Source #

Instance details

Defined in Kafka.Types

Methods

compare :: TopicType -> TopicType -> Ordering #

(<) :: TopicType -> TopicType -> Bool #

(<=) :: TopicType -> TopicType -> Bool #

(>) :: TopicType -> TopicType -> Bool #

(>=) :: TopicType -> TopicType -> Bool #

max :: TopicType -> TopicType -> TopicType #

min :: TopicType -> TopicType -> TopicType #

type Rep TopicType Source #

Instance details

Defined in Kafka.Types

type Rep TopicType = D1 ('MetaData "TopicType" "Kafka.Types" "hw-kafka-client-5.3.0-8OZSN6XHxJUEBGq88IRkoi" 'False) (C1 ('MetaCons "User" 'PrefixI 'False) (U1 :: Type -> Type) :+: C1 ('MetaCons "System" 'PrefixI 'False) (U1 :: Type -> Type))

data Headers Source #

Headers that might be passed along with a record

Instances

Instances details

Monoid Headers Source #

Instance details

Defined in Kafka.Types

Methods

mempty :: Headers #

mappend :: Headers -> Headers -> Headers #

mconcat :: [Headers] -> Headers #

Semigroup Headers Source #

Instance details

Defined in Kafka.Types

Methods

(<>) :: Headers -> Headers -> Headers #

sconcat :: NonEmpty Headers -> Headers #

stimes :: Integral b => b -> Headers -> Headers #

Generic Headers Source #

Instance details

Defined in Kafka.Types

Associated Types

type Rep Headers
Instance details Defined in Kafka.Types type Rep Headers = D1 ('MetaData "Headers" "Kafka.Types" "hw-kafka-client-5.3.0-8OZSN6XHxJUEBGq88IRkoi" 'True) (C1 ('MetaCons "Headers" 'PrefixI 'True) (S1 ('MetaSel ('Just "unHeaders") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 [(ByteString, ByteString)])))