kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From cmcc...@apache.org
Subject [kafka] branch trunk updated (d997dc6 -> 717c55b)
Date Thu, 01 Aug 2019 21:36:39 GMT
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


Mime
View raw message