rondagostino commented on a change in pull request #11606:
URL: https://github.com/apache/kafka/pull/11606#discussion_r782538135
##########
File path: core/src/test/scala/integration/kafka/server/QuorumTestHarness.scala
##########
@@ -196,14 +199,16 @@ abstract class QuorumTestHarness extends Logging {
}
}
- def createAndStartBroker(config: KafkaConfig,
- time: Time = Time.SYSTEM): KafkaBroker = {
- implementation.createAndStartBroker(config,
- time)
+ def createBroker(config: KafkaConfig,
+ time: Time = Time.SYSTEM,
+ startup: Boolean = true): KafkaBroker = {
+ implementation.createBroker(config, time, startup)
}
def shutdownZooKeeper(): Unit = asZk().shutdown()
+ def shutdownKRaftController(): Unit = asKRaft().shutdown()
Review comment:
Good point. There is no `shutdown()` method that we can invoke directly,
but here we do want the RaftManager to not be shut down, so I've adjusted the
method accordingly and kept the name.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
