This is an automated email from the ASF dual-hosted git repository.
davidarthur pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from e6f8ca8 MINOR: Fix log statement whose placeholders are inconsistent
with arguments (#10312)
add e820eb4 KAFKA-12383: Get RaftClusterTest.java and other KIP-500 junit
tests working (#10220)
No new revisions were added by this update.
Summary of changes:
checkstyle/import-control-core.xml | 16 +
core/src/main/scala/kafka/raft/RaftManager.scala | 5 +-
.../src/main/scala/kafka/server/BrokerServer.scala | 5 +-
.../main/scala/kafka/server/ControllerServer.scala | 6 +-
.../main/scala/kafka/server/KafkaRaftServer.scala | 7 +-
.../main/scala/kafka/tools/TestRaftServer.scala | 8 +-
core/src/test/java/kafka/test/ClusterInstance.java | 2 +-
.../java/kafka/test/ClusterTestExtensionsTest.java | 8 +-
core/src/test/java/kafka/test/annotation/Type.java | 38 +-
.../kafka/test/junit/ClusterTestExtensions.java | 19 +-
.../test/junit/RaftClusterInvocationContext.java | 196 ++++++++
core/src/test/java/kafka/testkit/BrokerNode.java | 99 +++++
.../test/java/kafka/testkit/ControllerNode.java | 63 +++
.../java/kafka/testkit/KafkaClusterTestKit.java | 494 +++++++++++++++++++++
.../AutoStart.java => testkit/TestKitNode.java} | 9 +-
core/src/test/java/kafka/testkit/TestKitNodes.java | 181 ++++++++
core/src/test/resources/log4j.properties | 5 +-
.../integration/kafka/server/RaftClusterTest.scala | 216 +++++++++
.../java/org/apache/kafka/raft/RaftConfig.java | 13 +-
19 files changed, 1342 insertions(+), 48 deletions(-)
create mode 100644
core/src/test/java/kafka/test/junit/RaftClusterInvocationContext.java
create mode 100644 core/src/test/java/kafka/testkit/BrokerNode.java
create mode 100644 core/src/test/java/kafka/testkit/ControllerNode.java
create mode 100644 core/src/test/java/kafka/testkit/KafkaClusterTestKit.java
copy core/src/test/java/kafka/{test/annotation/AutoStart.java =>
testkit/TestKitNode.java} (88%)
create mode 100644 core/src/test/java/kafka/testkit/TestKitNodes.java
create mode 100644
core/src/test/scala/integration/kafka/server/RaftClusterTest.scala
