This is an automated email from the ASF dual-hosted git repository.
guozhang pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 56bc507 MINOR: improve logging of tasks on shutdown (#7597)
add 465f810 KAFKA-8972 (2.4 blocker): correctly release lost partitions
during consumer.unsubscribe() (#7441)
No new revisions were added by this update.
Summary of changes:
.../kafka/clients/consumer/KafkaConsumer.java | 2 +-
.../consumer/internals/ConsumerCoordinator.java | 7 +-
.../kafka/clients/consumer/KafkaConsumerTest.java | 100 +++++++++++++++++----
.../internals/ConsumerCoordinatorTest.java | 30 ++++++-
.../internals/StreamsRebalanceListener.java | 6 +-
.../streams/processor/internals/TaskManager.java | 14 +++
tests/kafkatest/services/streams.py | 14 ++-
.../tests/streams/streams_broker_bounce_test.py | 13 +--
8 files changed, 157 insertions(+), 29 deletions(-)
