This is an automated email from the ASF dual-hosted git repository.
jsancio pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 28dcbad KAFKA-13457: SocketChannel in Acceptor#accept is not closed
upon IOException (#11504)
add e8b53ca KAFKA-13357; Store producer IDs in broker snapshots
No new revisions were added by this update.
Summary of changes:
.../unit/kafka/server/MetadataCacheTest.scala | 2 +-
.../unit/kafka/server/ReplicaManagerTest.scala | 8 +-
.../java/org/apache/kafka/image/MetadataDelta.java | 101 +++++++++++++++------
.../java/org/apache/kafka/image/MetadataImage.java | 29 +++++-
.../org/apache/kafka/image/ProducerIdsDelta.java} | 33 ++++---
.../{ClusterImage.java => ProducerIdsImage.java} | 59 ++++++------
.../org/apache/kafka/image/MetadataImageTest.java | 7 +-
...resImageTest.java => ProducerIdsImageTest.java} | 56 +++++-------
8 files changed, 179 insertions(+), 116 deletions(-)
copy metadata/src/{test/java/org/apache/kafka/image/MockSnapshotConsumer.java
=> main/java/org/apache/kafka/image/ProducerIdsDelta.java} (52%)
copy metadata/src/main/java/org/apache/kafka/image/{ClusterImage.java =>
ProducerIdsImage.java} (52%)
copy metadata/src/test/java/org/apache/kafka/image/{FeaturesImageTest.java =>
ProducerIdsImageTest.java} (51%)
