Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

KAFKA-15842: Correct handling of KafkaConsumer.committed for new consumer #14859

Merged
merged 10 commits into from
Dec 1, 2023
Merged

KAFKA-15842: Correct handling of KafkaConsumer.committed for new consumer #14859

Changes from 1 commit
Commits
Show all changes
10 commits
Select commit Hold shift + click to select a range
a024310
Merge pull request #2 from apache/trunk
AndrewJSchofield Nov 14, 2023
88f2e32
Merge branch 'apache:trunk' into trunk
AndrewJSchofield Nov 16, 2023
17eb4ef
Merge branch 'apache:trunk' into trunk
AndrewJSchofield Nov 20, 2023
b985806
Merge branch 'apache:trunk' into trunk
AndrewJSchofield Nov 21, 2023
9ed0a44
Merge branch 'apache:trunk' into trunk
AndrewJSchofield Nov 21, 2023
d4196c3
Merge branch 'apache:trunk' into trunk
AndrewJSchofield Nov 23, 2023
d773a48
Merge branch 'apache:trunk' into trunk
AndrewJSchofield Nov 24, 2023
c1479e8
Merge branch 'apache:trunk' into trunk
AndrewJSchofield Nov 28, 2023
7a6de9b
KAFKA-15842: Correct handling of KafkaConsumer.committed
AndrewJSchofield Nov 28, 2023
9a8e1f2
Turn off flaky seek test for new consumer pending investigation
AndrewJSchofield Nov 29, 2023
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Turn off flaky seek test for new consumer pending investigation
  • Loading branch information
@AndrewJSchofield
AndrewJSchofield committed Nov 29, 2023
commit 9a8e1f2f7109648481fe97a5e0a67845c237ea93
3 changes: 2 additions & 1 deletion core/src/test/scala/integration/kafka/api/PlaintextConsumerTest.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -594,8 +594,9 @@ class PlaintextConsumerTest extends BaseConsumerTest {
assertThrows(classOf[InvalidTopicException], () => consumer.partitionsFor(";3# ads,{234"))
}

// Temporarily do not run flaky test for consumer group protocol
@ParameterizedTest(name = TestInfoUtils.TestWithParameterizedQuorumAndGroupProtocolNames)
@MethodSource(Array("getTestQuorumAndGroupProtocolParametersAll"))
@MethodSource(Array("getTestQuorumAndGroupProtocolParametersGenericGroupProtocolOnly"))
Comment on lines -598 to +599
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

😭

def testSeek(quorum: String, groupProtocol: String): Unit = {
val consumer = createConsumer()
val totalRecords = 50L
Expand Down