hw-kafka-client-2.0.0: Kafka bindings for Haskell

Safe HaskellNone
LanguageHaskell2010

Kafka.Consumer.ConsumerProperties

Synopsis

Documentation

noAutoCommit :: ConsumerProperties Source #

Disables auto commit for the consumer

consumerLogLevel :: KafkaLogLevel -> ConsumerProperties Source #

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

compression :: KafkaCompressionCodec -> ConsumerProperties Source #

Sets the compression codec for the consumer.

suppressDisconnectLogs :: ConsumerProperties Source #

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

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

extraProp :: String -> String -> ConsumerProperties Source #

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

debugOptions :: [KafkaDebug] -> ConsumerProperties Source #

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

rebalanceCallback :: (KafkaConsumer -> KafkaError -> [TopicPartition] -> IO ()) -> KafkaConf -> IO () Source #

Sets a callback that is called when rebalance is needed.

Callback implementations suppose to watch for KafkaResponseError RdKafkaRespErrAssignPartitions and for KafkaResponseError RdKafkaRespErrRevokePartitions. Other error codes are not expected and would indicate something really bad happening in a system, or bugs in librdkafka itself.

A callback is expected to call assign according to the error code it receives.

offsetCommitCallback :: (KafkaConsumer -> KafkaError -> [TopicPartition] -> IO ()) -> KafkaConf -> IO () Source #

Sets a callback that is called when rebalance is needed.

The results of automatic or manual offset commits will be scheduled for this callback and is served by pollMessage.

A callback is expected to call assign according to the error code it receives.

If no partitions had valid offsets to commit this callback will be called with KafkaError == KafkaResponseError RdKafkaRespErrNoOffset which is not to be considered an error.