This is an automated email from the ASF dual-hosted git repository.
vvcephei pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 3daa348 MINOR: Upgrade to Scala 2.12.13 (#9981)
add 4d28391 KAFKA-10867: Improved task idling (#9840)
No new revisions were added by this update.
Summary of changes:
checkstyle/suppressions.xml | 2 +-
.../org/apache/kafka/streams/StreamsConfig.java | 9 +-
.../processor/internals/ActiveTaskCreator.java | 3 +-
.../processor/internals/PartitionGroup.java | 148 ++++++-
.../streams/processor/internals/StandbyTask.java | 6 +
.../streams/processor/internals/StreamTask.java | 68 ++-
.../streams/processor/internals/StreamThread.java | 12 +-
.../internals/StreamsPartitionAssignor.java | 2 +
.../kafka/streams/processor/internals/Task.java | 6 +
.../streams/processor/internals/TaskManager.java | 5 +-
.../integration/RegexSourceIntegrationTest.java | 1 +
.../SmokeTestDriverIntegrationTest.java | 1 -
.../integration/utils/IntegrationTestUtils.java | 3 +-
.../processor/internals/PartitionGroupTest.java | 360 ++++++++++++---
.../processor/internals/StreamTaskTest.java | 492 ++++++++++-----------
.../processor/internals/TaskManagerTest.java | 6 +
.../internals/testutil/LogCaptureAppender.java | 4 +
.../StreamThreadStateStoreProviderTest.java | 2 +-
.../apache/kafka/streams/TopologyTestDriver.java | 24 +-
19 files changed, 790 insertions(+), 364 deletions(-)
