This is an automated email from the ASF dual-hosted git repository.
chia7712 pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 21afc83f8ed HOTFIX: Fix testDeleteConsumerGroupOffsets (#19788)
21afc83f8ed is described below
commit 21afc83f8ed7773305fa2b6453d8de83e15c957f
Author: Ming-Yen Chung <[email protected]>
AuthorDate: Fri May 23 03:45:04 2025 +0800
HOTFIX: Fix testDeleteConsumerGroupOffsets (#19788)
Fix the change in
https://github.com/apache/kafka/pull/19380/files#r2102980872
Use `LinkedHashMap` instead of `Set` to preserve the order of elements.
Reviewers: Jhen-Yung Hsu <[email protected]>, Sanskar Jhajharia
<[email protected]>, Chia-Ping Tsai <[email protected]>
---
.../scala/integration/kafka/api/PlaintextAdminIntegrationTest.scala | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git
a/core/src/test/scala/integration/kafka/api/PlaintextAdminIntegrationTest.scala
b/core/src/test/scala/integration/kafka/api/PlaintextAdminIntegrationTest.scala
index be0c9dea17b..1fbc6523a92 100644
---
a/core/src/test/scala/integration/kafka/api/PlaintextAdminIntegrationTest.scala
+++
b/core/src/test/scala/integration/kafka/api/PlaintextAdminIntegrationTest.scala
@@ -2483,7 +2483,8 @@ class PlaintextAdminIntegrationTest extends
BaseAdminIntegrationTest {
consumer.commitSync()
// Test offset deletion while consuming
- val offsetDeleteResult =
client.deleteConsumerGroupOffsets(testGroupId, util.Set.of(tp1, tp2))
+ val partitions = new
util.LinkedHashSet[TopicPartition](util.List.of(tp1, tp2))
+ val offsetDeleteResult =
client.deleteConsumerGroupOffsets(testGroupId, partitions)
// Top level error will equal to the first partition level error
assertFutureThrows(classOf[GroupSubscribedToTopicException],
offsetDeleteResult.all())
