This is an automated email from the ASF dual-hosted git repository.
junrao pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 3ced942ad43 KAFKA-18710 Move DynamicClientQuotaPublisher to metadata
module (#20642)
add 6f4ce76d84b KAFKA-19479: at_least_once mode in Kafka Streams silently
drops messages when the producer fails with MESSAGE_TOO_LARGE, violating
delivery guarantees (#20285)
No new revisions were added by this update.
Summary of changes:
.../producer/internals/ProduceRequestResult.java | 75 +++++++-
.../clients/producer/internals/ProducerBatch.java | 30 +++-
.../producer/internals/RecordAccumulator.java | 7 +-
.../producer/internals/RecordAccumulatorTest.java | 99 +++++++++++
.../producer/RecordAccumulatorFlushBenchmark.java | 190 +++++++++++++++++++++
5 files changed, 395 insertions(+), 6 deletions(-)
create mode 100644
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/producer/RecordAccumulatorFlushBenchmark.java
