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 23de8cb MINOR: AbstractCoordinatorTest should close coordinator
explicitly (#10001)
add 7205cd3 KAFKA-12236; New meta.properties logic for KIP-500 (#9967)
No new revisions were added by this update.
Summary of changes:
.../main/java/org/apache/kafka/common/Uuid.java | 11 ++
.../java/org/apache/kafka/common/UuidTest.java | 13 ++
.../common/message/SimpleExampleMessageTest.java | 7 +-
.../common/message/SimpleExampleMessage.json | 2 +-
.../kafka/common/InconsistentNodeIdException.scala | 9 +-
.../scala/kafka/raft/KafkaNetworkChannel.scala | 5 +-
core/src/main/scala/kafka/raft/RaftManager.scala | 42 ++--
.../kafka/server/BrokerMetadataCheckpoint.scala | 217 ++++++++++++++++++---
core/src/main/scala/kafka/server/KafkaConfig.scala | 37 +++-
.../main/scala/kafka/server/KafkaRaftServer.scala | 54 ++++-
core/src/main/scala/kafka/server/KafkaServer.scala | 87 +++------
core/src/main/scala/kafka/server/Server.scala | 53 +++--
.../main/scala/kafka/tools/TestRaftServer.scala | 15 +-
.../server/BrokerMetadataCheckpointTest.scala | 135 ++++++++++++-
.../unit/kafka/raft/KafkaNetworkChannelTest.scala | 2 +-
.../scala/unit/kafka/raft/RaftManagerTest.scala | 4 +-
.../scala/unit/kafka/server/KafkaConfigTest.scala | 50 ++++-
.../unit/kafka/server/KafkaRaftServerTest.scala | 202 +++++++++++++++++++
.../kafka/server/ServerGenerateBrokerIdTest.scala | 5 +-
.../kafka/server/ServerGenerateClusterIdTest.scala | 8 +-
.../test/scala/unit/kafka/server/ServerTest.scala | 66 +++++++
raft/README.md | 6 +-
raft/config/raft.properties | 7 +-
23 files changed, 869 insertions(+), 168 deletions(-)
copy clients/src/test/java/org/apache/kafka/common/utils/SystemTimeTest.java
=> core/src/main/scala/kafka/common/InconsistentNodeIdException.scala (81%)
create mode 100644
core/src/test/scala/unit/kafka/server/KafkaRaftServerTest.scala
create mode 100644 core/src/test/scala/unit/kafka/server/ServerTest.scala
