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 c9bfcf02d22 KAFKA-20719: Add integration test for sticky task
assignment on startup (#22630)
add 238eb6e6a77 KAFKA-20116: Make task-end-offset-sum available to client
background thread (2/N) (#22608)
No new revisions were added by this update.
Summary of changes:
.../consumer/internals/StreamsRebalanceData.java | 10 ++-
.../consumer/internals/AsyncKafkaConsumerTest.java | 10 +--
.../consumer/internals/RequestManagersTest.java | 2 +-
.../StreamsGroupHeartbeatRequestManagerTest.java | 1 +
.../internals/StreamsRebalanceDataTest.java | 25 ++++--
.../kafka/api/AuthorizerIntegrationTest.scala | 1 +
.../kafka/api/IntegrationTestHarness.scala | 1 +
.../processor/internals/ChangelogReader.java | 5 ++
.../processor/internals/DefaultStateUpdater.java | 49 ++++++++++++
.../streams/processor/internals/StateUpdater.java | 8 ++
.../processor/internals/StoreChangelogReader.java | 17 ++++
.../streams/processor/internals/StreamThread.java | 15 ++--
.../streams/processor/internals/TaskManager.java | 8 ++
.../internals/DefaultStateUpdaterTest.java | 90 ++++++++++++++++++++++
.../DefaultStreamsRebalanceListenerTest.java | 10 ++-
.../processor/internals/MockChangelogReader.java | 5 ++
.../internals/StoreChangelogReaderTest.java | 27 +++++++
.../processor/internals/StreamThreadTest.java | 12 ++-
18 files changed, 273 insertions(+), 23 deletions(-)
