This is an automated email from the ASF dual-hosted git repository.
cmccabe pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from d997dc6 MINOR: Fix wrong debug log message (#7137)
add 717c55b KAFKA-8601: Implement KIP-480: Sticky Partitioning for
keyless records (#6997)
No new revisions were added by this update.
Summary of changes:
checkstyle/suppressions.xml | 2 +-
.../kafka/clients/producer/KafkaProducer.java | 27 +++-
.../apache/kafka/clients/producer/Partitioner.java | 10 ++
.../producer/internals/DefaultPartitioner.java | 50 +++----
.../producer/internals/RecordAccumulator.java | 18 ++-
.../producer/internals/StickyPartitionCache.java | 76 ++++++++++
.../producer/internals/TransactionManager.java | 4 +-
.../producer/internals/DefaultPartitionerTest.java | 80 ++---------
.../producer/internals/RecordAccumulatorTest.java | 151 +++++++++++++++----
.../clients/producer/internals/SenderTest.java | 160 +++++++++++----------
.../internals/StickyPartitionCacheTest.java | 110 ++++++++++++++
.../producer/internals/TransactionManagerTest.java | 135 ++++++++++++-----
12 files changed, 569 insertions(+), 254 deletions(-)
create mode 100644
clients/src/main/java/org/apache/kafka/clients/producer/internals/StickyPartitionCache.java
create mode 100644
clients/src/test/java/org/apache/kafka/clients/producer/internals/StickyPartitionCacheTest.java
