You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by mj...@apache.org on 2020/02/12 20:20:12 UTC
[kafka] branch trunk updated (2cbd3d7 -> aa0d0ec)
This is an automated email from the ASF dual-hosted git repository.
mjsax pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 2cbd3d7 KAFKA-9499; Improve deletion process by batching more aggressively (#8053)
add aa0d0ec KAFKA-6607: Commit correct offsets for transactional input data (#8091)
No new revisions were added by this update.
Summary of changes:
.../test/java/org/apache/kafka/test/TestUtils.java | 1 -
.../processor/internals/PartitionGroup.java | 35 ++++--
.../streams/processor/internals/RecordQueue.java | 4 +
.../streams/processor/internals/StreamTask.java | 17 ++-
.../streams/processor/internals/StreamThread.java | 14 +--
.../integration/AbstractResetIntegrationTest.java | 65 +++--------
.../streams/integration/EosIntegrationTest.java | 66 +++++++++--
.../integration/utils/IntegrationTestUtils.java | 46 +++++++-
.../processor/internals/PartitionGroupTest.java | 123 ++++++++++++++++++---
.../processor/internals/RecordQueueTest.java | 69 +++++++++---
.../processor/internals/StreamTaskTest.java | 76 +++++++++++--
.../apache/kafka/streams/TopologyTestDriver.java | 14 ++-
12 files changed, 399 insertions(+), 131 deletions(-)