You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by js...@apache.org on 2021/11/24 18:11:25 UTC
[kafka] branch trunk updated (28dcbad -> e8b53ca)
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%)