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 (1ae0956 -> bcc0237)
Date Tue, 24 Sep 2019 20:24:08 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 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(-)


Mime
View raw message