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 1ae0956 HOTFIX: fix Kafka Streams upgrade note for broker backward
compatibility (#7363)
add bcc0237 KAFKA-8880: Add overloaded function of Consumer.committed
(#7304)
No new revisions were added by this update.
Summary of changes:
.../apache/kafka/clients/consumer/Consumer.java | 12 ++++
.../kafka/clients/consumer/KafkaConsumer.java | 80 ++++++++++++++++++++--
.../kafka/clients/consumer/MockConsumer.java | 28 ++++++--
.../kafka/clients/consumer/KafkaConsumerTest.java | 20 +++---
.../kafka/clients/consumer/MockConsumerTest.java | 10 +--
.../integration/kafka/api/ConsumerBounceTest.scala | 6 +-
.../kafka/api/PlaintextConsumerTest.scala | 46 ++++++-------
.../integration/kafka/api/TransactionsTest.scala | 2 +-
.../kafka/admin/ConsumerGroupCommandTest.scala | 14 ++--
.../test/scala/unit/kafka/utils/TestUtils.scala | 9 +--
.../streams/processor/internals/AbstractTask.java | 20 ++++--
.../processor/internals/ProcessorStateManager.java | 9 ++-
.../streams/processor/internals/StandbyTask.java | 34 +++++----
.../streams/processor/internals/StreamTask.java | 50 +++++++-------
.../processor/internals/StandbyTaskTest.java | 8 +--
.../processor/internals/StreamTaskTest.java | 4 +-
.../kafka/tools/TransactionalMessageCopier.java | 10 +--
17 files changed, 235 insertions(+), 127 deletions(-)
