a76a745978
The change sets queue.buffering.max.messages configuration option for Kafka producer effectively limiting the number of messages in the buffer before sending them to Apache Kafka. Depends-On: https://review.opendev.org/694738 Change-Id: I6ebd4e21e9d55d1ac836e92dd8bf02a678170c68 Story: 2006059 Task: 37532 |
||
---|---|---|
.. | ||
message_formats | ||
__init__.py | ||
exceptions.py | ||
fake_publisher.py | ||
kafka_publisher.py | ||
publisher.py |