You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@kafka.apache.org by jg...@apache.org on 2021/02/04 00:18:03 UTC

[kafka] branch trunk updated (c64241f -> f58c2ac)

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