Kafka.Producer.ProducerProperties

Documentation

data ProducerProperties

Properties to create KafkaProducer.

Constructors

ProducerProperties

Fields

• ppKafkaProps :: Map String String
• ppTopicProps :: Map String String
• ppLogLevel :: Maybe KafkaLogLevel
• ppCallbacks :: [KafkaConf -> IO ()]

Instances

Monoid ProducerProperties

Right biased so we prefer newer properties over older ones.

Methods

mempty :: ProducerProperties

mappend :: ProducerProperties -> ProducerProperties -> ProducerProperties

mconcat :: [ProducerProperties] -> ProducerProperties

brokersList :: [BrokerAddress] -> ProducerProperties

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

logLevel :: KafkaLogLevel -> ProducerProperties

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

compression :: KafkaCompressionCodec -> ProducerProperties

topicCompression :: KafkaCompressionCodec -> ProducerProperties

sendTimeout :: Timeout -> ProducerProperties

extraProps :: Map String String -> ProducerProperties

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

suppressDisconnectLogs :: ProducerProperties

Suppresses producer disconnects logs.

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

extraTopicProps :: Map String String -> ProducerProperties

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

debugOptions :: [KafkaDebug] -> ProducerProperties

Sets debug features for the producer Usually is used with logLevel.

deliveryErrorsCallback :: (KafkaError -> IO ()) -> KafkaConf -> IO ()

Sets the callback for delivery errors. The callback is only called in case of errors.