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(-)
