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 a949334 KAFKA-8983; AdminClient deleteRecords should not fail all
partitions unnecessarily (#7449)
add c49775b KAFKA-7190; Retain producer state until
transactionalIdExpiration time passes (#7388)
No new revisions were added by this update.
Summary of changes:
core/src/main/scala/kafka/log/Log.scala | 1 -
.../scala/kafka/log/ProducerStateManager.scala | 58 +++-----------------
core/src/test/scala/unit/kafka/log/LogTest.scala | 13 +++--
.../unit/kafka/log/ProducerStateManagerTest.scala | 63 ++++------------------
4 files changed, 27 insertions(+), 108 deletions(-)
