You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Sameer Tejani (Jira)" <ji...@apache.org> on 2023/10/29 22:59:00 UTC
[jira] [Updated] (KAFKA-15739) KRaft support in ResetConsumerGroupOffsetTest
[ https://issues.apache.org/jira/browse/KAFKA-15739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Sameer Tejani updated KAFKA-15739:
----------------------------------
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
was:
The following tests in ConsumerWithLegacyMessageFormatIntegrationTest in core/src/test/scala/integration/kafka/api/ConsumerWithLegacyMessageFormatIntegrationTest.scala need to be updated to support KRaft
0 : def testOffsetsForTimes(): Unit = {
102 : def testEarliestOrLatestOffsets(): Unit = {
Scanned 132 lines. Found 0 KRaft tests out of 2 tests
> KRaft support in ResetConsumerGroupOffsetTest
> ---------------------------------------------
>
> Key: KAFKA-15739
> URL: https://issues.apache.org/jira/browse/KAFKA-15739
> Project: Kafka
> Issue Type: Task
> Components: core
> Reporter: Sameer Tejani
> Priority: Minor
> Labels: kraft, kraft-test, newbie
>
> 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
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)