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

Posted to commits@kafka.apache.org by jg...@apache.org on 2020/02/16 06:47:37 UTC

[kafka] branch trunk updated (d8756e8 -> 937f1f7)

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

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


    from d8756e8  KAFKA-9274: Gracefully handle timeout exception (#8060)
     add 937f1f7  KAFKA-8805; Bump producer epoch on recoverable errors (#7389)

No new revisions were added by this update.

Summary of changes:
 checkstyle/suppressions.xml                        |   4 +-
 .../kafka/clients/producer/KafkaProducer.java      |   8 +-
 .../clients/producer/internals/ProducerBatch.java  |   6 +
 .../producer/internals/RecordAccumulator.java      |  23 +-
 .../kafka/clients/producer/internals/Sender.java   |  42 +-
 .../producer/internals/TransactionManager.java     | 468 +++++++++----
 .../producer/internals/RecordAccumulatorTest.java  |   3 +-
 .../clients/producer/internals/SenderTest.java     | 315 ++++++---
 .../producer/internals/TransactionManagerTest.java | 739 ++++++++++++++++++---
 .../kafka/api/TransactionsBounceTest.scala         |   3 +-
 .../kafka/api/TransactionsExpirationTest.scala     | 122 ++++
 .../integration/kafka/api/TransactionsTest.scala   | 129 +++-
 .../test/scala/unit/kafka/utils/TestUtils.scala    |  19 +-
 13 files changed, 1449 insertions(+), 432 deletions(-)
 create mode 100644 core/src/test/scala/integration/kafka/api/TransactionsExpirationTest.scala