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

Posted to commits@kafka.apache.org by gu...@apache.org on 2020/04/03 04:49:13 UTC

[kafka] branch trunk updated (6ddbf4d -> 7f640f1)

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 6ddbf4d  KAFKA-9809: Shrink transaction timeout for streams (#8407)
     add 7f640f1  KAFKA-9776: Downgrade TxnCommit API v3 when broker doesn't support (#8375)

No new revisions were added by this update.

Summary of changes:
 .../kafka/clients/producer/KafkaProducer.java      |  26 +-
 .../kafka/clients/producer/ProducerConfig.java     |  21 +-
 .../producer/internals/TransactionManager.java     |  29 +-
 .../common/requests/TxnOffsetCommitRequest.java    |  39 +-
 .../kafka/clients/producer/KafkaProducerTest.java  |  42 +-
 .../producer/internals/RecordAccumulatorTest.java  |   2 +-
 .../clients/producer/internals/SenderTest.java     |  18 +-
 .../producer/internals/TransactionManagerTest.java | 825 +++++++++------------
 .../kafka/common/requests/RequestResponseTest.java |  30 +-
 .../requests/TxnOffsetCommitRequestTest.java       |  69 +-
 .../scala/unit/kafka/server/KafkaApisTest.scala    |   6 +-
 .../scala/unit/kafka/server/RequestQuotaTest.scala |  15 +-
 .../org/apache/kafka/streams/StreamsConfig.java    |   5 +
 .../apache/kafka/streams/StreamsConfigTest.java    |  22 +
 .../streams/streams_broker_compatibility_test.py   |   6 +-
 15 files changed, 579 insertions(+), 576 deletions(-)