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/08/12 15:54:39 UTC
[kafka] branch trunk updated (89e12f3 -> b937ec7)

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 89e12f3  KAFKA-10388; Fix struct conversion logic for tagged structures (#9166)
     add b937ec7  KAFKA-9911: Add new PRODUCER_FENCED error code (#8549)

No new revisions were added by this update.

Summary of changes:
 .../producer/internals/TransactionManager.java     |  36 ++-
 .../kafka/common/errors/RetriableException.java    |   2 +-
 .../InvalidProducerEpochException.java}            |  18 +-
 .../org/apache/kafka/common/protocol/Errors.java   |  12 +-
 .../common/requests/AddOffsetsToTxnResponse.java   |   3 +-
 .../requests/AddPartitionsToTxnResponse.java       |   3 +-
 .../kafka/common/requests/EndTxnResponse.java      |   3 +-
 .../common/requests/InitProducerIdResponse.java    |  13 +-
 .../common/message/AddOffsetsToTxnRequest.json     |   4 +-
 .../common/message/AddOffsetsToTxnResponse.json    |   4 +-
 .../common/message/AddPartitionsToTxnRequest.json  |   4 +-
 .../common/message/AddPartitionsToTxnResponse.json |   4 +-
 .../resources/common/message/EndTxnRequest.json    |   4 +-
 .../resources/common/message/EndTxnResponse.json   |   4 +-
 .../common/message/InitProducerIdRequest.json      |   4 +-
 .../common/message/InitProducerIdResponse.json     |   4 +-
 .../producer/internals/TransactionManagerTest.java | 149 +++++++++-
 .../transaction/TransactionCoordinator.scala       |  10 +-
 .../transaction/TransactionMetadata.scala          |   4 +-
 core/src/main/scala/kafka/server/KafkaApis.scala   |  43 ++-
 .../transaction/TransactionCoordinatorTest.scala   |  21 +-
 .../transaction/TransactionMetadataTest.scala      |   2 +-
 .../scala/unit/kafka/server/KafkaApisTest.scala    | 312 ++++++++++++++++++---
 23 files changed, 546 insertions(+), 117 deletions(-)
 copy clients/src/main/java/org/apache/kafka/common/{errors/OffsetOutOfRangeException.java => internals/InvalidProducerEpochException.java} (66%)