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/03/31 00:47:36 UTC

[kafka] branch trunk updated (6ad5407 -> 75e8ee1)

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 6ad5407  KAFKA-9719: Streams with EOS-beta should fail fast for older brokers (#8367)
     add 75e8ee1  KAFKA-9777; Remove txn purgatory to fix race condition on txn completion (#8389)

No new revisions were added by this update.

Summary of changes:
 .../coordinator/transaction/DelayedTxnMarker.scala |  49 -------
 .../transaction/TransactionCoordinator.scala       |  12 +-
 .../TransactionMarkerChannelManager.scala          | 155 ++++++++++++---------
 .../transaction/TransactionStateManager.scala      |  22 ++-
 .../TransactionCoordinatorConcurrencyTest.scala    |  36 +++--
 .../TransactionMarkerChannelManagerTest.scala      |  59 ++++----
 .../transaction/TransactionStateManagerTest.scala  |  18 ++-
 7 files changed, 163 insertions(+), 188 deletions(-)
 delete mode 100644 core/src/main/scala/kafka/coordinator/transaction/DelayedTxnMarker.scala