MINOR: convert some more junit tests to support KRaft (#12456)
* MINOR: convert some more junit tests to support KRaft Introduce TestUtils#waitUntilLeaderIsElectedOrChangedWithAdmin, a ZK-free alternative to TestUtils#waitUntilLeaderIsElectedOrChanged. Convert PlaintextProducerSendTest, SslProducerSendTest, TransactionsWithMaxInFlightOneTest, AddPartitionsToTxnRequestServerTest and KafkaMetricsReporterTest to support KRaft Reviewers: dengziming <dengziming1993@gmail.com>, David Arthur <mumrah@gmail.com>
显示
- core/src/test/scala/integration/kafka/api/BaseProducerSendTest.scala 61 个添加, 41 个删除...st/scala/integration/kafka/api/BaseProducerSendTest.scala
- core/src/test/scala/integration/kafka/api/PlaintextProducerSendTest.scala 29 个添加, 22 个删除...ala/integration/kafka/api/PlaintextProducerSendTest.scala
- core/src/test/scala/integration/kafka/api/TransactionsWithMaxInFlightOneTest.scala 13 个添加, 11 个删除...ration/kafka/api/TransactionsWithMaxInFlightOneTest.scala
- core/src/test/scala/integration/kafka/server/QuorumTestHarness.scala 26 个添加, 14 个删除...st/scala/integration/kafka/server/QuorumTestHarness.scala
- core/src/test/scala/unit/kafka/server/AddPartitionsToTxnRequestServerTest.scala 10 个添加, 6 个删除...it/kafka/server/AddPartitionsToTxnRequestServerTest.scala
- core/src/test/scala/unit/kafka/server/KafkaMetricsReporterTest.scala 32 个添加, 23 个删除...st/scala/unit/kafka/server/KafkaMetricsReporterTest.scala
- core/src/test/scala/unit/kafka/utils/TestUtils.scala 55 个添加, 5 个删除core/src/test/scala/unit/kafka/utils/TestUtils.scala
加载中
想要评论请 注册 或 登录