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 f6d6bcc MINOR: Print the cached broker epoch (#11005)
add 526fdfb MINOR: the broker should use
metadata.log.max.record.bytes.between.snapshots (#10990)
No new revisions were added by this update.
Summary of changes:
build.gradle | 1 +
.../src/main/scala/kafka/server/BrokerServer.scala | 38 +++++-
.../server/metadata/BrokerMetadataListener.scala | 89 ++++++++++----
.../metadata/BrokerMetadataSnapshotter.scala | 113 ++++++++++++++++++
...taPublisher.scala => MetadataSnapshotter.scala} | 26 +++--
.../metadata/BrokerMetadataListenerTest.scala | 130 ++++++++++++++++++++-
.../metadata/BrokerMetadataSnapshotterTest.scala | 103 ++++++++++++++++
.../apache/kafka/metadata/MetadataRecordSerde.java | 1 +
.../org/apache/kafka/image/MetadataImageTest.java | 6 +-
.../org/apache/kafka/metadata/RecordTestUtils.java | 15 ++-
10 files changed, 473 insertions(+), 49 deletions(-)
create mode 100644
core/src/main/scala/kafka/server/metadata/BrokerMetadataSnapshotter.scala
copy core/src/main/scala/kafka/server/metadata/{MetadataPublisher.scala =>
MetadataSnapshotter.scala} (51%)
create mode 100644
core/src/test/scala/unit/kafka/server/metadata/BrokerMetadataSnapshotterTest.scala
