You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@kafka.apache.org by bo...@apache.org on 2020/11/18 03:57:51 UTC

[kafka] branch trunk updated (e71cb7a -> e709017)

This is an automated email from the ASF dual-hosted git repository.

boyang pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.


    from e71cb7a  KAFKA-10689: fix windowed FKJ topology and put checks in assignor to avoid infinite loops (#9568)
     add e709017  KAFKA-10687: make ProduceRespone only returns INVALID_PRODUCER_EPOCH (#9569)

No new revisions were added by this update.

Summary of changes:
 .../apache/kafka/clients/producer/Callback.java    |  1 +
 .../kafka/clients/producer/KafkaProducer.java      |  6 +++
 .../producer/internals/TransactionManager.java     |  7 ++--
 .../InvalidProducerEpochException.java             | 11 +++--
 .../org/apache/kafka/common/protocol/Errors.java   |  2 +-
 .../producer/internals/TransactionManagerTest.java |  6 +--
 .../scala/kafka/log/ProducerStateManager.scala     |  5 ++-
 .../integration/kafka/api/TransactionsTest.scala   |  6 +--
 core/src/test/scala/unit/kafka/log/LogTest.scala   |  4 +-
 .../unit/kafka/log/ProducerStateManagerTest.scala  |  6 +--
 .../scala/unit/kafka/server/KafkaApisTest.scala    | 47 ++++++++++++++++++++++
 .../processor/internals/StreamsProducer.java       |  3 +-
 .../processor/internals/StreamsProducerTest.java   | 19 +++++++++
 13 files changed, 99 insertions(+), 24 deletions(-)
 rename clients/src/main/java/org/apache/kafka/common/{internals => errors}/InvalidProducerEpochException.java (78%)