Kafka.Producer.ProducerProperties

Documentation

data ProducerProperties

Properties to create KafkaProducer.

Constructors

ProducerProperties

Fields

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

Instances

Semigroup ProducerProperties

Defined in Kafka.Producer.ProducerProperties

Methods

(<>) :: ProducerProperties -> ProducerProperties -> ProducerProperties

sconcat :: NonEmpty ProducerProperties -> ProducerProperties

stimes :: Integral b => b -> ProducerProperties -> ProducerProperties

Monoid ProducerProperties

Right biased so we prefer newer properties over older ones.

Defined in Kafka.Producer.ProducerProperties

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 Text Text -> 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 Text Text -> 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.

deliveryCallback :: (DeliveryReport -> IO ()) -> KafkaConf -> IO ()

Sets the callback for delivery reports.

errorCallback :: HasKafkaConf k => (KafkaError -> String -> IO ()) -> k -> IO ()

logCallback :: HasKafkaConf k => (Int -> String -> String -> IO ()) -> k -> IO ()

statsCallback :: HasKafkaConf k => (String -> IO ()) -> k -> IO ()