Details
-
Task
-
Status: Patch Available
-
Minor
-
Resolution: Unresolved
-
None
-
None
Description
The following tests in ResetConsumerGroupOffsetTest in core/src/test/scala/unit/kafka/admin/ResetConsumerGroupOffsetTest.scala need to be updated to support KRaft
75 : def testResetOffsetsNotExistingGroup(): Unit = {
89 : def testResetOffsetsExistingTopic(): Unit = {
99 : def testResetOffsetsExistingTopicSelectedGroups(): Unit = {
116 : def testResetOffsetsExistingTopicAllGroups(): Unit = {
130 : def testResetOffsetsAllTopicsAllGroups(): Unit = {
149 : def testResetOffsetsToLocalDateTime(): Unit = {
165 : def testResetOffsetsToZonedDateTime(): Unit = {
181 : def testResetOffsetsByDuration(): Unit = {
188 : def testResetOffsetsByDurationToEarliest(): Unit = {
195 : def testResetOffsetsByDurationFallbackToLatestWhenNoRecords(): Unit = {
205 : def testResetOffsetsToEarliest(): Unit = {
212 : def testResetOffsetsToLatest(): Unit = {
220 : def testResetOffsetsToCurrentOffset(): Unit = {
228 : def testResetOffsetsToSpecificOffset(): Unit = {
235 : def testResetOffsetsShiftPlus(): Unit = {
243 : def testResetOffsetsShiftMinus(): Unit = {
251 : def testResetOffsetsShiftByLowerThanEarliest(): Unit = {
259 : def testResetOffsetsShiftByHigherThanLatest(): Unit = {
267 : def testResetOffsetsToEarliestOnOneTopic(): Unit = {
274 : def testResetOffsetsToEarliestOnOneTopicAndPartition(): Unit = {
293 : def testResetOffsetsToEarliestOnTopics(): Unit = {
318 : def testResetOffsetsToEarliestOnTopicsAndPartitions(): Unit = {
348 : def testResetOffsetsExportImportPlanSingleGroupArg(): Unit = {
378 : def testResetOffsetsExportImportPlan(): Unit = {
425 : def testResetWithUnrecognizedNewConsumerOption(): Unit = {
Scanned 515 lines. Found 0 KRaft tests out of 25 tests
Attachments
Issue Links
- is blocked by
-
KAFKA-14589 Move ConsumerGroupCommand to tools
-
- Resolved
-
- relates to
-
KAFKA-16598 Mirgrate `ResetConsumerGroupOffsetTest` to new test infra
-
- Resolved
-
- links to