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
data TopicType
- = User
- | System
topicType :: TopicName -> TopicType
kafkaDebugToText :: KafkaDebug -> Text
kafkaCompressionCodecToText :: KafkaCompressionCodec -> Text

Documentation

newtype BrokerId Source #

Kafka broker ID

Constructors

BrokerId
Fields unBrokerId :: Int

Instances

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 #
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 #
Generic BrokerId Source #
Instance details 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 Source #
Instance details Defined in Kafka.Types type Rep BrokerId = D1 (MetaData "BrokerId" "Kafka.Types" "hw-kafka-client-4.0.2-inplace" 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

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] #
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 #
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 #
Generic PartitionId Source #
Instance details 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 Source #
Instance details Defined in Kafka.Types type Rep PartitionId = D1 (MetaData "PartitionId" "Kafka.Types" "hw-kafka-client-4.0.2-inplace" 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

Eq Millis Source #
Instance details Defined in Kafka.Types Methods (==) :: Millis -> Millis -> Bool # (/=) :: Millis -> Millis -> Bool #
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 #
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 #
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 #
Generic Millis Source #
Instance details 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 Source #
Instance details Defined in Kafka.Types type Rep Millis = D1 (MetaData "Millis" "Kafka.Types" "hw-kafka-client-4.0.2-inplace" 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

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 #
Show ClientId Source #
Instance details Defined in Kafka.Types Methods showsPrec :: Int -> ClientId -> ShowS # show :: ClientId -> String # showList :: [ClientId] -> ShowS #
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 :: Type -> Type # Methods from :: ClientId -> Rep ClientId x # to :: Rep ClientId x -> ClientId #
type Rep ClientId Source #
Instance details Defined in Kafka.Types type Rep ClientId = D1 (MetaData "ClientId" "Kafka.Types" "hw-kafka-client-4.0.2-inplace" 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

Eq BatchSize Source #
Instance details Defined in Kafka.Types Methods (==) :: BatchSize -> BatchSize -> Bool # (/=) :: BatchSize -> BatchSize -> Bool #
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 #
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 #
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 #
Generic BatchSize Source #
Instance details 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 Source #
Instance details Defined in Kafka.Types type Rep BatchSize = D1 (MetaData "BatchSize" "Kafka.Types" "hw-kafka-client-4.0.2-inplace" 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

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 #
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 #
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 :: Type -> Type # Methods from :: TopicName -> Rep TopicName x # to :: Rep TopicName x -> TopicName #
type Rep TopicName Source #
Instance details Defined in Kafka.Types type Rep TopicName = D1 (MetaData "TopicName" "Kafka.Types" "hw-kafka-client-4.0.2-inplace" 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

Eq BrokerAddress Source #
Instance details Defined in Kafka.Types Methods (==) :: BrokerAddress -> BrokerAddress -> Bool # (/=) :: BrokerAddress -> BrokerAddress -> Bool #
Show BrokerAddress Source #
Instance details Defined in Kafka.Types Methods showsPrec :: Int -> BrokerAddress -> ShowS # show :: BrokerAddress -> String # showList :: [BrokerAddress] -> ShowS #
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 :: Type -> Type # Methods from :: BrokerAddress -> Rep BrokerAddress x # to :: Rep BrokerAddress x -> BrokerAddress #
type Rep BrokerAddress Source #
Instance details Defined in Kafka.Types type Rep BrokerAddress = D1 (MetaData "BrokerAddress" "Kafka.Types" "hw-kafka-client-4.0.2-inplace" 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

Eq Timeout Source #
Instance details Defined in Kafka.Types Methods (==) :: Timeout -> Timeout -> Bool # (/=) :: Timeout -> Timeout -> Bool #
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 #
Generic Timeout Source #
Instance details 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 Source #
Instance details Defined in Kafka.Types type Rep Timeout = D1 (MetaData "Timeout" "Kafka.Types" "hw-kafka-client-4.0.2-inplace" 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

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

data KafkaError Source #

All possible Kafka errors

Constructors

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

Instances

Eq KafkaError Source #
Instance details Defined in Kafka.Types Methods (==) :: KafkaError -> KafkaError -> Bool # (/=) :: KafkaError -> KafkaError -> Bool #
Show KafkaError Source #
Instance details Defined in Kafka.Types Methods showsPrec :: Int -> KafkaError -> ShowS # show :: KafkaError -> String # showList :: [KafkaError] -> ShowS #
Generic KafkaError Source #
Instance details Defined in Kafka.Types Associated Types type Rep KafkaError :: Type -> Type # Methods from :: KafkaError -> Rep KafkaError x # to :: Rep KafkaError x -> KafkaError #
Exception KafkaError Source #
Instance details Defined in Kafka.Types Methods toException :: KafkaError -> SomeException # fromException :: SomeException -> Maybe KafkaError # displayException :: KafkaError -> String #
type Rep KafkaError Source #
Instance details Defined in Kafka.Types type Rep KafkaError = D1 (MetaData "KafkaError" "Kafka.Types" "hw-kafka-client-4.0.2-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 Source #

Available librdkafka debug contexts

Constructors

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

Instances

Eq KafkaDebug Source #
Instance details Defined in Kafka.Types Methods (==) :: KafkaDebug -> KafkaDebug -> Bool # (/=) :: KafkaDebug -> KafkaDebug -> Bool #
Show KafkaDebug Source #
Instance details Defined in Kafka.Types Methods showsPrec :: Int -> KafkaDebug -> ShowS # show :: KafkaDebug -> String # showList :: [KafkaDebug] -> ShowS #
Generic KafkaDebug Source #
Instance details 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 Source #
Instance details Defined in Kafka.Types type Rep KafkaDebug = D1 (MetaData "KafkaDebug" "Kafka.Types" "hw-kafka-client-4.0.2-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 Source #

Compression codec used by a topic

See Kafka documentation on compression codecs

Constructors

NoCompression
Gzip
Snappy
Lz4

Instances

Eq KafkaCompressionCodec Source #
Instance details Defined in Kafka.Types Methods (==) :: KafkaCompressionCodec -> KafkaCompressionCodec -> Bool # (/=) :: KafkaCompressionCodec -> KafkaCompressionCodec -> Bool #
Show KafkaCompressionCodec Source #
Instance details Defined in Kafka.Types Methods showsPrec :: Int -> KafkaCompressionCodec -> ShowS # show :: KafkaCompressionCodec -> String # showList :: [KafkaCompressionCodec] -> ShowS #
Generic KafkaCompressionCodec Source #
Instance details 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 Source #
Instance details Defined in Kafka.Types type Rep KafkaCompressionCodec = D1 (MetaData "KafkaCompressionCodec" "Kafka.Types" "hw-kafka-client-4.0.2-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 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

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 #
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 #
Generic TopicType Source #
Instance details 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 Source #
Instance details Defined in Kafka.Types type Rep TopicType = D1 (MetaData "TopicType" "Kafka.Types" "hw-kafka-client-4.0.2-inplace" False) (C1 (MetaCons "User" PrefixI False) (U1 :: Type -> Type) :+: C1 (MetaCons "System" PrefixI False) (U1 :: Type -> Type))

topicType :: TopicName -> TopicType Source #

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

kafkaDebugToText :: KafkaDebug -> Text Source #

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

Convert a KafkaCompressionCodec into its librdkafka string equivalent.

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