kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject [kafka] branch trunk updated (56bc507 -> 465f810)
Date Tue, 29 Oct 2019 17:41:45 GMT
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(-)


Mime
View raw message