Sameer Tejani created KAFKA-15737: ------------------------------------- Summary: KRaft support in ConsumerBounceTest Key: KAFKA-15737 URL: https://issues.apache.org/jira/browse/KAFKA-15737 Project: Kafka Issue Type: Task Components: core Reporter: Sameer Tejani
The following tests in PlaintextConsumerTest in core/src/test/scala/integration/kafka/api/PlaintextConsumerTest.scala need to be updated to support KRaft 49 : def testHeaders(): Unit = { 136 : def testDeprecatedPollBlocksForAssignment(): Unit = { 144 : def testHeadersSerializerDeserializer(): Unit = { 153 : def testMaxPollRecords(): Unit = { 169 : def testMaxPollIntervalMs(): Unit = { 194 : def testMaxPollIntervalMsDelayInRevocation(): Unit = { 234 : def testMaxPollIntervalMsDelayInAssignment(): Unit = { 258 : def testAutoCommitOnClose(): Unit = { 281 : def testAutoCommitOnCloseAfterWakeup(): Unit = { 308 : def testAutoOffsetReset(): Unit = { 319 : def testGroupConsumption(): Unit = { 339 : def testPatternSubscription(): Unit = { 396 : def testSubsequentPatternSubscription(): Unit = { 447 : def testPatternUnsubscription(): Unit = { 473 : def testCommitMetadata(): Unit = { 494 : def testAsyncCommit(): Unit = { 513 : def testExpandingTopicSubscriptions(): Unit = { 527 : def testShrinkingTopicSubscriptions(): Unit = { 541 : def testPartitionsFor(): Unit = { 551 : def testPartitionsForAutoCreate(): Unit = { 560 : def testPartitionsForInvalidTopic(): Unit = { 566 : def testSeek(): Unit = { 621 : def testPositionAndCommit(): Unit = { 653 : def testPartitionPauseAndResume(): Unit = { 671 : def testFetchInvalidOffset(): Unit = { 696 : def testFetchOutOfRangeOffsetResetConfigEarliest(): Unit = { 717 : def testFetchOutOfRangeOffsetResetConfigLatest(): Unit = { 743 : def testFetchRecordLargerThanFetchMaxBytes(): Unit = { 772 : def testFetchHonoursFetchSizeIfLargeRecordNotFirst(): Unit = { 804 : def testFetchHonoursMaxPartitionFetchBytesIfLargeRecordNotFirst(): Unit = { 811 : def testFetchRecordLargerThanMaxPartitionFetchBytes(): Unit = { 819 : def testLowMaxFetchSizeForRequestAndPartition(): Unit = { 867 : def testRoundRobinAssignment(): Unit = { 903 : def testMultiConsumerRoundRobinAssignor(): Unit = { 940 : def testMultiConsumerStickyAssignor(): Unit = { 986 : def testMultiConsumerDefaultAssignor(): Unit = { 1024 : def testRebalanceAndRejoin(assignmentStrategy: String): Unit = { 1109 : def testMultiConsumerDefaultAssignorAndVerifyAssignment(): Unit = { 1141 : def testMultiConsumerSessionTimeoutOnStopPolling(): Unit = { 1146 : def testMultiConsumerSessionTimeoutOnClose(): Unit = { 1151 : def testInterceptors(): Unit = { 1210 : def testAutoCommitIntercept(): Unit = { 1260 : def testInterceptorsWithWrongKeyValue(): Unit = { 1286 : def testConsumeMessagesWithCreateTime(): Unit = { 1303 : def testConsumeMessagesWithLogAppendTime(): Unit = { 1331 : def testListTopics(): Unit = { 1351 : def testUnsubscribeTopic(): Unit = { 1367 : def testPauseStateNotPreservedByRebalance(): Unit = { 1388 : def testCommitSpecifiedOffsets(): Unit = { 1415 : def testAutoCommitOnRebalance(): Unit = { 1454 : def testPerPartitionLeadMetricsCleanUpWithSubscribe(): Unit = { 1493 : def testPerPartitionLagMetricsCleanUpWithSubscribe(): Unit = { 1533 : def testPerPartitionLeadMetricsCleanUpWithAssign(): Unit = { 1562 : def testPerPartitionLagMetricsCleanUpWithAssign(): Unit = { 1593 : def testPerPartitionLagMetricsWhenReadCommitted(): Unit = { 1616 : def testPerPartitionLeadWithMaxPollRecords(): Unit = { 1638 : def testPerPartitionLagWithMaxPollRecords(): Unit = { 1661 : def testQuotaMetricsNotCreatedIfNoQuotasConfigured(): Unit = { 1809 : def testConsumingWithNullGroupId(): Unit = { 1874 : def testConsumingWithEmptyGroupId(): Unit = { 1923 : def testStaticConsumerDetectsNewPartitionCreatedAfterRestart(): Unit = { Scanned 1951 lines. Found 0 KRaft tests out of 61 tests -- This message was sent by Atlassian Jira (v8.20.10#820010)