Details
-
Task
-
Status: Open
-
Minor
-
Resolution: Unresolved
-
None
-
None
Description
The following tests in ConsumerBounceTest in core/src/test/scala/integration/kafka/api/ConsumerBounceTest.scala need to be updated to support KRaft
81 : def testConsumptionWithBrokerFailures(): Unit = consumeWithBrokerFailures(10)
122 : def testSeekAndCommitWithBrokerFailures(): Unit = seekAndCommitWithBrokerFailures(5)
161 : def testSubscribeWhenTopicUnavailable(): Unit = {
212 : def testClose(): Unit = {
297 : def testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup(): Unit = {
337 : def testConsumerReceivesFatalExceptionWhenGroupPassesMaxSize(): Unit = {
370 : def testCloseDuringRebalance(): Unit = {
Scanned 535 lines. Found 0 KRaft tests out of 7 tests
Attachments
Issue Links
- links to