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(-)
