Kafka.Consumer.ConsumerProperties

Documentation

data ConsumerProperties

Properties to create KafkaConsumer.

Constructors

ConsumerProperties

Fields

• cpProps :: Map String String
• cpLogLevel :: Maybe KafkaLogLevel
• cpCallbacks :: [KafkaConf -> IO ()]

Instances

Semigroup ConsumerProperties

Methods

(<>) :: ConsumerProperties -> ConsumerProperties -> ConsumerProperties

sconcat :: NonEmpty ConsumerProperties -> ConsumerProperties

stimes :: Integral b => b -> ConsumerProperties -> ConsumerProperties

Monoid ConsumerProperties

Right biased so we prefer newer properties over older ones.

Methods

mempty :: ConsumerProperties

mappend :: ConsumerProperties -> ConsumerProperties -> ConsumerProperties

mconcat :: [ConsumerProperties] -> ConsumerProperties

brokersList :: [BrokerAddress] -> ConsumerProperties

noAutoCommit :: ConsumerProperties

Disables auto commit for the consumer

noAutoOffsetStore :: ConsumerProperties

Disables auto offset store for the consumer

groupId :: ConsumerGroupId -> ConsumerProperties

Consumer group id

clientId :: ClientId -> ConsumerProperties

setCallback :: (KafkaConf -> IO ()) -> ConsumerProperties

logLevel :: KafkaLogLevel -> ConsumerProperties

Sets the logging level. Usually is used with debugOptions to configure which logs are needed.

compression :: KafkaCompressionCodec -> ConsumerProperties

Sets the compression codec for the consumer.

suppressDisconnectLogs :: ConsumerProperties

Suppresses consumer disconnects logs.

It might be useful to turn this off when interacting with brokers with an aggressive connection.max.idle.ms value.

extraProps :: Map String String -> ConsumerProperties

Any configuration options that are supported by librdkafka. The full list can be found here

extraProp :: String -> String -> ConsumerProperties

Any configuration options that are supported by librdkafka. The full list can be found here

debugOptions :: [KafkaDebug] -> ConsumerProperties

Sets debug features for the consumer. Usually is used with consumerLogLevel.

queuedMaxMessagesKBytes :: Int -> ConsumerProperties