Kafka.Types

Module holding types shared by consumer and producer modules.

Documentation

newtype BrokerId

Kafka broker ID

Constructors

BrokerId

Fields

• unBrokerId :: Int

Instances

Eq BrokerId

Defined in Kafka.Types

Methods

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

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

Ord BrokerId

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

Read BrokerId

Defined in Kafka.Types

Methods

readsPrec :: Int -> ReadS BrokerId

readList :: ReadS [BrokerId]

readPrec :: ReadPrec BrokerId

readListPrec :: ReadPrec [BrokerId]

Show BrokerId

Defined in Kafka.Types

Methods

showsPrec :: Int -> BrokerId -> ShowS

show :: BrokerId -> String

showList :: [BrokerId] -> ShowS

Generic BrokerId

Defined in Kafka.Types

Associated Types

type Rep BrokerId :: Type -> Type

Methods

from :: BrokerId -> Rep BrokerId x

to :: Rep BrokerId x -> BrokerId

type Rep BrokerId

Defined in Kafka.Types

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

newtype PartitionId

Topic partition ID

Constructors

PartitionId

Fields

• unPartitionId :: Int

Instances

Enum PartitionId

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]

Eq PartitionId

Defined in Kafka.Types

Methods

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

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

Ord PartitionId

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

Read PartitionId

Defined in Kafka.Types

Methods

readsPrec :: Int -> ReadS PartitionId

readList :: ReadS [PartitionId]

readPrec :: ReadPrec PartitionId

readListPrec :: ReadPrec [PartitionId]

Show PartitionId

Defined in Kafka.Types

Methods

showsPrec :: Int -> PartitionId -> ShowS

show :: PartitionId -> String

showList :: [PartitionId] -> ShowS

Generic PartitionId

Defined in Kafka.Types

Associated Types

type Rep PartitionId :: Type -> Type

Methods

from :: PartitionId -> Rep PartitionId x

to :: Rep PartitionId x -> PartitionId

type Rep PartitionId

Defined in Kafka.Types

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

newtype Millis

A number of milliseconds, used to represent durations and timestamps

Constructors

Millis

Fields

• unMillis :: Int64

Instances

Eq Millis

Defined in Kafka.Types

Methods

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

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

Num Millis

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

Ord Millis

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

Read Millis

Defined in Kafka.Types

Methods

readsPrec :: Int -> ReadS Millis

readList :: ReadS [Millis]

readPrec :: ReadPrec Millis

readListPrec :: ReadPrec [Millis]

Show Millis

Defined in Kafka.Types

Methods

showsPrec :: Int -> Millis -> ShowS

show :: Millis -> String

showList :: [Millis] -> ShowS

Generic Millis

Defined in Kafka.Types

Associated Types

type Rep Millis :: Type -> Type

Methods

from :: Millis -> Rep Millis x

to :: Rep Millis x -> Millis

type Rep Millis

Defined in Kafka.Types

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

newtype ClientId

Client ID used by Kafka to better track requests

See Kafka documentation on client ID

Constructors

ClientId

Fields

• unClientId :: Text

Instances

Eq ClientId

Defined in Kafka.Types

Methods

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

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

Ord ClientId

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

Show ClientId

Defined in Kafka.Types

Methods

showsPrec :: Int -> ClientId -> ShowS

show :: ClientId -> String

showList :: [ClientId] -> ShowS

IsString ClientId

Defined in Kafka.Types

Methods

fromString :: String -> ClientId

Generic ClientId

Defined in Kafka.Types

Associated Types

type Rep ClientId :: Type -> Type

Methods

from :: ClientId -> Rep ClientId x

to :: Rep ClientId x -> ClientId

type Rep ClientId

Defined in Kafka.Types

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

newtype BatchSize

Batch size used for polling

Constructors

BatchSize

Fields

• unBatchSize :: Int

Instances

Eq BatchSize

Defined in Kafka.Types

Methods

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

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

Num BatchSize

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

Ord BatchSize

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

Read BatchSize

Defined in Kafka.Types

Methods

readsPrec :: Int -> ReadS BatchSize

readList :: ReadS [BatchSize]

readPrec :: ReadPrec BatchSize

readListPrec :: ReadPrec [BatchSize]

Show BatchSize

Defined in Kafka.Types

Methods

showsPrec :: Int -> BatchSize -> ShowS

show :: BatchSize -> String

showList :: [BatchSize] -> ShowS

Generic BatchSize

Defined in Kafka.Types

Associated Types

type Rep BatchSize :: Type -> Type

Methods

from :: BatchSize -> Rep BatchSize x

to :: Rep BatchSize x -> BatchSize

type Rep BatchSize

Defined in Kafka.Types

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

newtype TopicName

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

Eq TopicName

Defined in Kafka.Types

Methods

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

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

Ord TopicName

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

Read TopicName

Defined in Kafka.Types

Methods

readsPrec :: Int -> ReadS TopicName

readList :: ReadS [TopicName]

readPrec :: ReadPrec TopicName

readListPrec :: ReadPrec [TopicName]

Show TopicName

Defined in Kafka.Types

Methods

showsPrec :: Int -> TopicName -> ShowS

show :: TopicName -> String

showList :: [TopicName] -> ShowS

IsString TopicName

Defined in Kafka.Types

Methods

fromString :: String -> TopicName

Generic TopicName

Defined in Kafka.Types

Associated Types

type Rep TopicName :: Type -> Type

Methods

from :: TopicName -> Rep TopicName x

to :: Rep TopicName x -> TopicName

type Rep TopicName

Defined in Kafka.Types

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

newtype BrokerAddress

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

Constructors

BrokerAddress

Fields

• unBrokerAddress :: Text

Instances

Eq BrokerAddress

Defined in Kafka.Types

Methods

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

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

Show BrokerAddress

Defined in Kafka.Types

Methods

showsPrec :: Int -> BrokerAddress -> ShowS

show :: BrokerAddress -> String

showList :: [BrokerAddress] -> ShowS

IsString BrokerAddress

Defined in Kafka.Types

Methods

fromString :: String -> BrokerAddress

Generic BrokerAddress

Defined in Kafka.Types

Associated Types

type Rep BrokerAddress :: Type -> Type

Methods

from :: BrokerAddress -> Rep BrokerAddress x

to :: Rep BrokerAddress x -> BrokerAddress

type Rep BrokerAddress

Defined in Kafka.Types

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

newtype Timeout

Timeout in milliseconds

Constructors

Timeout

Fields

• unTimeout :: Int

Instances

Eq Timeout

Defined in Kafka.Types

Methods

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

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

Read Timeout

Defined in Kafka.Types

Methods

readsPrec :: Int -> ReadS Timeout

readList :: ReadS [Timeout]

readPrec :: ReadPrec Timeout

readListPrec :: ReadPrec [Timeout]

Show Timeout

Defined in Kafka.Types

Methods

showsPrec :: Int -> Timeout -> ShowS

show :: Timeout -> String

showList :: [Timeout] -> ShowS

Generic Timeout

Defined in Kafka.Types

Associated Types

type Rep Timeout :: Type -> Type

Methods

from :: Timeout -> Rep Timeout x

to :: Rep Timeout x -> Timeout

type Rep Timeout

Defined in Kafka.Types

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

data KafkaLogLevel

Log levels for librdkafka.

Constructors

KafkaLogEmerg

KafkaLogAlert

KafkaLogCrit

KafkaLogErr

KafkaLogWarning

KafkaLogNotice

KafkaLogInfo

KafkaLogDebug

Instances

Enum KafkaLogLevel

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]

Eq KafkaLogLevel

Defined in Kafka.Types

Methods

(==) :: KafkaLogLevel -> KafkaLogLevel -> Bool

(/=) :: KafkaLogLevel -> KafkaLogLevel -> Bool

Show KafkaLogLevel

Defined in Kafka.Types

Methods

showsPrec :: Int -> KafkaLogLevel -> ShowS

show :: KafkaLogLevel -> String

showList :: [KafkaLogLevel] -> ShowS

data KafkaError

All possible Kafka errors

Constructors

KafkaError Text

KafkaInvalidReturnValue

KafkaBadSpecification Text

KafkaResponseError RdKafkaRespErrT

KafkaInvalidConfigurationValue Text

KafkaUnknownConfigurationKey Text

KafkaBadConfiguration

Instances

Eq KafkaError

Defined in Kafka.Types

Methods

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

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

Show KafkaError

Defined in Kafka.Types

Methods

showsPrec :: Int -> KafkaError -> ShowS

show :: KafkaError -> String

showList :: [KafkaError] -> ShowS

Generic KafkaError

Defined in Kafka.Types

Associated Types

type Rep KafkaError :: Type -> Type

Methods

from :: KafkaError -> Rep KafkaError x

to :: Rep KafkaError x -> KafkaError

Exception KafkaError

Defined in Kafka.Types

Methods

toException :: KafkaError -> SomeException

fromException :: SomeException -> Maybe KafkaError

displayException :: KafkaError -> String

type Rep KafkaError

Defined in Kafka.Types

type Rep KafkaError = D1 ('MetaData "KafkaError" "Kafka.Types" "hw-kafka-client-5.0.0-inplace" '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

Available librdkafka debug contexts

Constructors

DebugGeneric

DebugBroker

DebugTopic

DebugMetadata

DebugQueue

DebugMsg

DebugProtocol

DebugCgrp

DebugSecurity

DebugFetch

DebugFeature

DebugAll

Instances

Eq KafkaDebug

Defined in Kafka.Types

Methods

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

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

Show KafkaDebug

Defined in Kafka.Types

Methods

showsPrec :: Int -> KafkaDebug -> ShowS

show :: KafkaDebug -> String

showList :: [KafkaDebug] -> ShowS

Generic KafkaDebug

Defined in Kafka.Types

Associated Types

type Rep KafkaDebug :: Type -> Type

Methods

from :: KafkaDebug -> Rep KafkaDebug x

to :: Rep KafkaDebug x -> KafkaDebug

type Rep KafkaDebug

Defined in Kafka.Types

type Rep KafkaDebug = D1 ('MetaData "KafkaDebug" "Kafka.Types" "hw-kafka-client-5.0.0-inplace" '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

Compression codec used by a topic

See Kafka documentation on compression codecs

Constructors

NoCompression

Gzip

Snappy

Lz4

Instances

Eq KafkaCompressionCodec

Defined in Kafka.Types

Methods

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

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

Show KafkaCompressionCodec

Defined in Kafka.Types

Methods

showsPrec :: Int -> KafkaCompressionCodec -> ShowS

show :: KafkaCompressionCodec -> String

showList :: [KafkaCompressionCodec] -> ShowS

Generic KafkaCompressionCodec

Defined in Kafka.Types

Associated Types

type Rep KafkaCompressionCodec :: Type -> Type

Methods

from :: KafkaCompressionCodec -> Rep KafkaCompressionCodec x

to :: Rep KafkaCompressionCodec x -> KafkaCompressionCodec

type Rep KafkaCompressionCodec

Defined in Kafka.Types

type Rep KafkaCompressionCodec = D1 ('MetaData "KafkaCompressionCodec" "Kafka.Types" "hw-kafka-client-5.0.0-inplace" '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)))

data TopicType

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

Eq TopicType

Defined in Kafka.Types

Methods

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

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

Ord TopicType

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

Read TopicType

Defined in Kafka.Types

Methods

readsPrec :: Int -> ReadS TopicType

readList :: ReadS [TopicType]

readPrec :: ReadPrec TopicType

readListPrec :: ReadPrec [TopicType]

Show TopicType

Defined in Kafka.Types

Methods

showsPrec :: Int -> TopicType -> ShowS

show :: TopicType -> String

showList :: [TopicType] -> ShowS

Generic TopicType

Defined in Kafka.Types

Associated Types

type Rep TopicType :: Type -> Type

Methods

from :: TopicType -> Rep TopicType x

to :: Rep TopicType x -> TopicType

type Rep TopicType

Defined in Kafka.Types

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

data Headers

Headers that might be passed along with a record

Instances

Eq Headers

Defined in Kafka.Types

Methods

(==) :: Headers -> Headers -> Bool

(/=) :: Headers -> Headers -> Bool

Read Headers

Defined in Kafka.Types

Methods

readsPrec :: Int -> ReadS Headers

readList :: ReadS [Headers]

readPrec :: ReadPrec Headers

readListPrec :: ReadPrec [Headers]

Show Headers

Defined in Kafka.Types

Methods

showsPrec :: Int -> Headers -> ShowS

show :: Headers -> String

showList :: [Headers] -> ShowS

Generic Headers

Defined in Kafka.Types

Associated Types

type Rep Headers :: Type -> Type

Methods

from :: Headers -> Rep Headers x

to :: Rep Headers x -> Headers

Semigroup Headers

Defined in Kafka.Types

Methods

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

sconcat :: NonEmpty Headers -> Headers

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

Monoid Headers

Defined in Kafka.Types

Methods

mempty :: Headers

mappend :: Headers -> Headers -> Headers

mconcat :: [Headers] -> Headers

type Rep Headers

Defined in Kafka.Types

type Rep Headers = D1 ('MetaData "Headers" "Kafka.Types" "hw-kafka-client-5.0.0-inplace" 'True) (C1 ('MetaCons "Headers" 'PrefixI 'True) (S1 ('MetaSel ('Just "unHeaders") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 [(ByteString, ByteString)])))

headersFromList :: [(ByteString, ByteString)] -> Headers

headersToList :: Headers -> [(ByteString, ByteString)]

topicType :: TopicName -> TopicType

Deduce the type of a topic from its name, by checking if it starts with a double underscore "__"

kafkaDebugToText :: KafkaDebug -> Text

Convert a KafkaDebug into its librdkafka string equivalent.

This is used internally by the library but may be useful to some developers.

kafkaCompressionCodecToText :: KafkaCompressionCodec -> Text

Convert a KafkaCompressionCodec into its librdkafka string equivalent.

This is used internally by the library but may be useful to some developers.