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 2021/07/28 01:24:28 UTC

[kafka] branch trunk updated (f6f6e52 -> c5ec390)

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 f6f6e52  KAFKA-13139: Empty response after requesting to restart a connector without the tasks results in NPE (#11132)
     add c5ec390  KAFKA-13099; Transactional expiration should account for max batch size (#11098)

No new revisions were added by this update.

Summary of changes:
 .../apache/kafka/common/record/MemoryRecords.java  |  14 ++
 .../transaction/TransactionMetadata.scala          |   5 +
 .../transaction/TransactionStateManager.scala      | 208 +++++++++++-----
 core/src/main/scala/kafka/utils/Pool.scala         |  11 +-
 .../AbstractCoordinatorConcurrencyTest.scala       |   7 +-
 .../TransactionCoordinatorConcurrencyTest.scala    |  10 +-
 .../transaction/TransactionStateManagerTest.scala  | 262 ++++++++++++++++++---
 7 files changed, 418 insertions(+), 99 deletions(-)