This is an automated email from the ASF dual-hosted git repository.
AndrewJSchofield 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 2dfdb70ba73 MINOR: Fix typo in testConsumerGroupHeartbeatRebalance
(#22119)
2dfdb70ba73 is described below
commit 2dfdb70ba73e7b6d884d48f1ac42f358ff791d93
Author: Sean Quah <[email protected]>
AuthorDate: Tue Apr 28 16:53:26 2026 +0100
MINOR: Fix typo in testConsumerGroupHeartbeatRebalance (#22119)
Fix an incorrect assertion in ConsumerGroupHeartbeatRequestTest's
testConsumerGroupHeartbeatRebalance.
Reviewers: Andrew Schofield <[email protected]>
---
.../scala/unit/kafka/server/ConsumerGroupHeartbeatRequestTest.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/core/src/test/scala/unit/kafka/server/ConsumerGroupHeartbeatRequestTest.scala
b/core/src/test/scala/unit/kafka/server/ConsumerGroupHeartbeatRequestTest.scala
index 908bd74494d..72293bce687 100644
---
a/core/src/test/scala/unit/kafka/server/ConsumerGroupHeartbeatRequestTest.scala
+++
b/core/src/test/scala/unit/kafka/server/ConsumerGroupHeartbeatRequestTest.scala
@@ -1258,7 +1258,7 @@ class ConsumerGroupHeartbeatRequestTest(cluster:
ClusterInstance) extends GroupC
).build()
val response4 = connectAndReceive[ConsumerGroupHeartbeatResponse](request4)
- assertEquals(Errors.NONE.code, response3.data.errorCode)
+ assertEquals(Errors.NONE.code, response4.data.errorCode)
val expectedAssignment4 = new
ConsumerGroupHeartbeatResponseData.Assignment()
.setTopicPartitions(List(new
ConsumerGroupHeartbeatResponseData.TopicPartitions()
