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)
