This is an automated email from the ASF dual-hosted git repository.
jgus pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from c64241f KAFKA-12259: Use raw config to infer the connector type when
returning a connector status response (#10040)
add f58c2ac KAFKA-12250; Add metadata record serde for KIP-631 (#9998)
No new revisions were added by this update.
Summary of changes:
build.gradle | 1 +
checkstyle/import-control.xml | 2 +
.../main/scala/kafka/tools/TestRaftServer.scala | 6 +-
.../kafka/message/MetadataRecordTypeGenerator.java | 14 ++++-
.../kafka/metadata/ApiMessageAndVersion.java | 38 +++++-------
.../java/org/apache/kafka/raft/RecordSerde.java | 33 +++++-----
.../kafka/raft/internals/BatchAccumulator.java | 7 ++-
.../apache/kafka/raft/internals/BatchBuilder.java | 15 ++---
.../apache/kafka/raft/internals/StringSerde.java | 5 +-
.../kafka/raft/metadata/MetadataRecordSerde.java | 66 ++++++++++++++++++++
.../apache/kafka/raft/RaftEventSimulationTest.java | 5 +-
.../kafka/raft/internals/BatchAccumulatorTest.java | 8 ++-
.../raft/metadata/MetadataRecordSerdeTest.java | 72 ++++++++++++++++++++++
13 files changed, 211 insertions(+), 61 deletions(-)
copy tools/src/main/java/org/apache/kafka/trogdor/rest/ErrorResponse.java =>
metadata/src/main/java/org/apache/kafka/metadata/ApiMessageAndVersion.java (61%)
create mode 100644
raft/src/main/java/org/apache/kafka/raft/metadata/MetadataRecordSerde.java
create mode 100644
raft/src/test/java/org/apache/kafka/raft/metadata/MetadataRecordSerdeTest.java
