Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-15737

KRaft support in ConsumerBounceTest

Attach filesAttach ScreenshotAdd voteVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

Details

    • Task
    • Status: Open
    • Minor
    • Resolution: Unresolved
    • None
    • None
    • core

    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

        Activity

          This comment will be Viewable by All Users Viewable by All Users
          Cancel

          People

            frankvicky TengYao Chi
            sameert Sameer Tejani

            Dates

              Created:
              Updated:

              Slack

                Issue deployment