Modules§
Structs§
- See https://github.com/confluentinc/librdkafka/blob/master/CONFIGURATION.md for the detailed meaning of these librdkafka producer properties
Enums§
Constants§
- The default queue size used to enforce a commit in kafka producer if
queue.buffering.max.messagesis not specified. This default value is determined based on the librdkafka default. See the following doc for more details: https://github.com/confluentinc/librdkafka/blob/1cb80090dfc75f5a36eae3f4f8844b14885c045e/CONFIGURATION.md - When the
DeliveryFuturethe currentfuture_delivery_bufferis buffering is greater thanqueue_buffering_max_messages*KAFKA_WRITER_MAX_QUEUE_SIZE_RATIO, then enforcing commit once