This is an automated email from the ASF dual-hosted git repository.
mjsax 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 2443b6f2641 MINOR: Fix KafkaApisTest sharePartitionManager and
ShareSessionContext parameters (#20848)
2443b6f2641 is described below
commit 2443b6f2641749e1f30ada4cdbff60f3b5d2ac15
Author: lucliu1108 <[email protected]>
AuthorDate: Fri Nov 7 18:13:51 2025 -0600
MINOR: Fix KafkaApisTest sharePartitionManager and ShareSessionContext
parameters (#20848)
Follow up on
https://github.com/apache/kafka/commit/cc62985c2a1cc9fa0b330b0d6f08b6be5b5c8fc1,
the input for `sharePartitionManager.newContext()` and
`ShareSessionContext()` seems to be broken.
Reviewers: TaiJuWu <[email protected]>, Matthias J. Sax
<[email protected]>
---
core/src/test/scala/unit/kafka/server/KafkaApisTest.scala | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/core/src/test/scala/unit/kafka/server/KafkaApisTest.scala
b/core/src/test/scala/unit/kafka/server/KafkaApisTest.scala
index 16352842300..d3c11408465 100644
--- a/core/src/test/scala/unit/kafka/server/KafkaApisTest.scala
+++ b/core/src/test/scala/unit/kafka/server/KafkaApisTest.scala
@@ -4593,8 +4593,8 @@ class KafkaApisTest extends Logging {
))
)
- when(sharePartitionManager.newContext(any(), any(), any(), any(), any(),
any())).thenReturn(
- new ShareSessionContext(new ShareRequestMetadata(memberId,
shareSessionEpoch), util.List.of(
+ when(sharePartitionManager.newContext(any(), any(), any(), any(), any(),
any(), any())).thenReturn(
+ new ShareSessionContext(shareSessionEpoch, util.List.of(
new TopicIdPartition(topicId, partitionIndex, topicName)))
)
