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 18e60cb0001 KAFKA-12497: Skip periodic offset commits for failed
source tasks (#10528)
add dac81161dbf MINOR; Introduce ImageWriter and ImageWriterOptions
(#12715)
No new revisions were added by this update.
Summary of changes:
checkstyle/import-control.xml | 8 +-
.../server/metadata/BrokerMetadataListener.scala | 21 +--
.../metadata/BrokerMetadataSnapshotter.scala | 39 ++----
.../metadata/BrokerMetadataSnapshotterTest.scala | 18 ---
.../java/org/apache/kafka/image/AclsImage.java | 16 +--
.../org/apache/kafka/image/ClientQuotaImage.java | 19 ++-
.../org/apache/kafka/image/ClientQuotasImage.java | 9 +-
.../java/org/apache/kafka/image/ClusterImage.java | 13 +-
.../org/apache/kafka/image/ConfigurationImage.java | 19 ++-
.../apache/kafka/image/ConfigurationsImage.java | 9 +-
.../java/org/apache/kafka/image/FeaturesImage.java | 52 +++++---
.../java/org/apache/kafka/image/MetadataImage.java | 26 ++--
.../org/apache/kafka/image/ProducerIdsDelta.java | 5 +
.../org/apache/kafka/image/ProducerIdsImage.java | 13 +-
.../java/org/apache/kafka/image/TopicImage.java | 18 +--
.../java/org/apache/kafka/image/TopicsImage.java | 9 +-
.../org/apache/kafka/image/writer/ImageWriter.java | 65 +++++++++
.../image/writer/ImageWriterClosedException.java | 10 +-
.../kafka/image/writer/ImageWriterOptions.java | 81 ++++++++++++
.../kafka/image/writer/RaftSnapshotWriter.java | 69 ++++++++++
.../kafka/image/writer/RecordListWriter.java} | 29 ++--
.../image/writer/UnwritableMetadataException.java | 34 +++--
.../apache/kafka/metadata/BrokerRegistration.java | 14 +-
.../kafka/metadata/PartitionRegistration.java | 3 +-
.../controller/ReplicationControlManagerTest.java | 2 +-
.../java/org/apache/kafka/image/AclsImageTest.java | 8 +-
.../apache/kafka/image/ClientQuotasImageTest.java | 8 +-
.../org/apache/kafka/image/ClusterImageTest.java | 13 +-
.../kafka/image/ConfigurationsImageTest.java | 8 +-
.../org/apache/kafka/image/FeaturesImageTest.java | 8 +-
.../org/apache/kafka/image/ImageDowngradeTest.java | 147 +++++++++++++++++++++
.../org/apache/kafka/image/MetadataImageTest.java | 12 +-
.../apache/kafka/image/ProducerIdsImageTest.java | 8 +-
.../org/apache/kafka/image/TopicsImageTest.java | 8 +-
.../kafka/image/writer/RaftSnapshotWriterTest.java | 105 +++++++++++++++
.../kafka/image/writer/RecordListWriterTest.java | 61 +++++++++
.../kafka/metadata/BrokerRegistrationTest.java | 8 +-
.../org/apache/kafka/metadata/RecordTestUtils.java | 18 +++
.../placement/StripedReplicaPlacerTest.java | 2 +-
.../org/apache/kafka/server/util}/MockRandom.java | 14 +-
40 files changed, 804 insertions(+), 225 deletions(-)
create mode 100644
metadata/src/main/java/org/apache/kafka/image/writer/ImageWriter.java
copy shell/src/main/java/org/apache/kafka/shell/NotFileException.java =>
metadata/src/main/java/org/apache/kafka/image/writer/ImageWriterClosedException.java
(81%)
create mode 100644
metadata/src/main/java/org/apache/kafka/image/writer/ImageWriterOptions.java
create mode 100644
metadata/src/main/java/org/apache/kafka/image/writer/RaftSnapshotWriter.java
rename
metadata/src/{test/java/org/apache/kafka/image/MockSnapshotConsumer.java =>
main/java/org/apache/kafka/image/writer/RecordListWriter.java} (59%)
copy
clients/src/main/java/org/apache/kafka/common/errors/ListenerNotFoundException.java
=>
metadata/src/main/java/org/apache/kafka/image/writer/UnwritableMetadataException.java
(53%)
create mode 100644
metadata/src/test/java/org/apache/kafka/image/ImageDowngradeTest.java
create mode 100644
metadata/src/test/java/org/apache/kafka/image/writer/RaftSnapshotWriterTest.java
create mode 100644
metadata/src/test/java/org/apache/kafka/image/writer/RecordListWriterTest.java
rename {metadata/src/test/java/org/apache/kafka/metadata =>
server-common/src/test/java/org/apache/kafka/server/util}/MockRandom.java (80%)
