You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by cm...@apache.org on 2022/12/12 17:52:17 UTC
[kafka] branch trunk updated (43f39c2e602 -> b2dea170411)
This is an automated email from the ASF dual-hosted git repository.
cmccabe pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 43f39c2e602 KAFKA-14379: Consumer should refresh preferred read replica on update metadata (#12956)
add b2dea170411 MINOR: Introduce MetadataProvenance and ImageReWriter (#12964)
No new revisions were added by this update.
Summary of changes:
.../server/metadata/BrokerMetadataListener.scala | 19 +++--
.../kafka/zk/ZkMigrationIntegrationTest.scala | 6 +-
.../unit/kafka/server/MetadataCacheTest.scala | 25 +++---
.../server/ReplicaManagerConcurrencyTest.scala | 8 +-
.../unit/kafka/server/ReplicaManagerTest.scala | 5 +-
.../metadata/BrokerMetadataSnapshotterTest.scala | 18 +++--
.../java/org/apache/kafka/image/MetadataDelta.java | 51 +++++-------
.../java/org/apache/kafka/image/MetadataImage.java | 26 ++++--
.../org/apache/kafka/image/MetadataProvenance.java | 92 ++++++++++++++++++++++
.../apache/kafka/image/MetadataVersionChange.java | 77 ++++++++++++++++++
.../image/MetadataVersionChangeException.java | 22 +++---
.../{RecordListWriter.java => ImageReWriter.java} | 34 +++++---
.../kafka/image/writer/ImageWriterOptions.java | 17 +++-
.../org/apache/kafka/image/ImageDowngradeTest.java | 4 +-
.../org/apache/kafka/image/MetadataImageTest.java | 34 ++++----
.../kafka/image/MetadataVersionChangeTest.java | 63 +++++++++++++++
...dListWriterTest.java => ImageReWriterTest.java} | 22 +++---
.../kafka/image/writer/ImageWriterOptionsTest.java | 52 ++++++++++++
.../org/apache/kafka/metadata/RecordTestUtils.java | 48 -----------
19 files changed, 444 insertions(+), 179 deletions(-)
create mode 100644 metadata/src/main/java/org/apache/kafka/image/MetadataProvenance.java
create mode 100644 metadata/src/main/java/org/apache/kafka/image/MetadataVersionChange.java
copy streams/src/main/java/org/apache/kafka/streams/errors/UnknownStateStoreException.java => metadata/src/main/java/org/apache/kafka/image/MetadataVersionChangeException.java (64%)
copy metadata/src/main/java/org/apache/kafka/image/writer/{RecordListWriter.java => ImageReWriter.java} (61%)
create mode 100644 metadata/src/test/java/org/apache/kafka/image/MetadataVersionChangeTest.java
copy metadata/src/test/java/org/apache/kafka/image/writer/{RecordListWriterTest.java => ImageReWriterTest.java} (71%)
create mode 100644 metadata/src/test/java/org/apache/kafka/image/writer/ImageWriterOptionsTest.java