This is an automated email from the ASF dual-hosted git repository.
bbejeck pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from cca0225 Fix missing reference in kafka.py (#7715)
add 41a9e2c HOTFIX: safely clear all active state in onPartitionsLost
(#7691)
No new revisions were added by this update.
Summary of changes:
.../consumer/ConsumerRebalanceListener.java | 3 +-
.../processor/internals/AssignedStandbyTasks.java | 3 +-
.../processor/internals/AssignedStreamsTasks.java | 128 +++++++++++----------
.../streams/processor/internals/AssignedTasks.java | 64 +++++++----
.../processor/internals/StoreChangelogReader.java | 2 +-
.../internals/StreamsRebalanceListener.java | 6 +-
.../streams/processor/internals/TaskManager.java | 58 +++-------
.../internals/AssignedStreamsTasksTest.java | 62 +++-------
8 files changed, 156 insertions(+), 170 deletions(-)
