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