Safe Haskell | Safe |
---|---|
Language | Haskell2010 |
- data ProducerProperties = ProducerProperties {}
- producerBrokersList :: [BrokerAddress] -> ProducerProperties
- producerLogLevel :: KafkaLogLevel -> ProducerProperties
- producerCompression :: KafkaCompressionCodec -> ProducerProperties
- producerTopicCompression :: KafkaCompressionCodec -> ProducerProperties
- extraProducerProps :: Map String String -> ProducerProperties
- producerSuppressDisconnectLogs :: ProducerProperties
- extraProducerTopicProps :: Map String String -> ProducerProperties
- producerDebug :: [KafkaDebug] -> ProducerProperties
Documentation
producerLogLevel :: KafkaLogLevel -> ProducerProperties Source #
Sets the logging level.
Usually is used with producerDebug
to configure which logs are needed.
extraProducerProps :: Map String String -> ProducerProperties Source #
Any configuration options that are supported by librdkafka. The full list can be found here
producerSuppressDisconnectLogs :: ProducerProperties Source #
Suppresses producer disconnects logs.
It might be useful to turn this off when interacting with brokers with an aggressive connection.max.idle.ms value.
extraProducerTopicProps :: Map String String -> ProducerProperties Source #
Any configuration options that are supported by librdkafka. The full list can be found here
producerDebug :: [KafkaDebug] -> ProducerProperties Source #
Sets debug features for the producer
Usually is used with producerLogLevel
.