Safe Haskell | None |
---|---|
Language | Haskell2010 |
- data ProducerProperties = ProducerProperties {
- ppKafkaProps :: Map String String
- ppTopicProps :: Map String String
- ppLogLevel :: Maybe KafkaLogLevel
- ppCallbacks :: [KafkaConf -> IO ()]
- brokersList :: [BrokerAddress] -> ProducerProperties
- setCallback :: (KafkaConf -> IO ()) -> ProducerProperties
- logLevel :: KafkaLogLevel -> ProducerProperties
- compression :: KafkaCompressionCodec -> ProducerProperties
- topicCompression :: KafkaCompressionCodec -> ProducerProperties
- sendTimeout :: Timeout -> ProducerProperties
- extraProps :: Map String String -> ProducerProperties
- suppressDisconnectLogs :: ProducerProperties
- extraTopicProps :: Map String String -> ProducerProperties
- debugOptions :: [KafkaDebug] -> ProducerProperties
- deliveryCallback :: (DeliveryReport -> IO ()) -> KafkaConf -> IO ()
Documentation
data ProducerProperties Source #
Properties to create KafkaProducer
.
ProducerProperties | |
|
Semigroup ProducerProperties Source # | |
Monoid ProducerProperties Source # | Right biased so we prefer newer properties over older ones. |
setCallback :: (KafkaConf -> IO ()) -> ProducerProperties Source #
logLevel :: KafkaLogLevel -> ProducerProperties Source #
Sets the logging level.
Usually is used with debugOptions
to configure which logs are needed.
extraProps :: Map String String -> ProducerProperties Source #
Any configuration options that are supported by librdkafka. The full list can be found here
suppressDisconnectLogs :: 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.
extraTopicProps :: Map String String -> ProducerProperties Source #
Any configuration options that are supported by librdkafka. The full list can be found here
debugOptions :: [KafkaDebug] -> ProducerProperties Source #
Sets debug features for the producer
Usually is used with logLevel
.
deliveryCallback :: (DeliveryReport -> IO ()) -> KafkaConf -> IO () Source #
Sets the callback for delivery reports.