Skip to content

Commit 42604b4

Browse files
lucliu1108lucasbruCopilot
authored
KAFKA-19807: Add RPC-level integration tests for StreamsGroupHeartbeat [1/2] (#20757)
## What Ticket: https://issues.apache.org/jira/browse/KAFKA-19807 Add integration test similar to `ShareGroupHeartbeatRequestTest` and `ConsumerGroupHeartbeatRequestTest` for `StreamsGroupHeartbeat` Reviewers: Lucas Brutschy <[email protected]> --------- Co-authored-by: Lucas Brutschy <[email protected]> Co-authored-by: Copilot <[email protected]>
1 parent 9550867 commit 42604b4

File tree

2 files changed

+541
-0
lines changed

2 files changed

+541
-0
lines changed

core/src/test/scala/unit/kafka/server/GroupCoordinatorBaseRequestTest.scala

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -880,6 +880,7 @@ class GroupCoordinatorBaseRequestTest(cluster: ClusterInstance) {
880880
warmupTasks: List[StreamsGroupHeartbeatRequestData.TaskIds] = null,
881881
topology: StreamsGroupHeartbeatRequestData.Topology = null,
882882
expectedError: Errors = Errors.NONE,
883+
processId: String = null,
883884
version: Short = ApiKeys.STREAMS_GROUP_HEARTBEAT.latestVersion(isUnstableApiEnabled)
884885
): StreamsGroupHeartbeatResponseData = {
885886
val streamsGroupHeartbeatRequest = new StreamsGroupHeartbeatRequest.Builder(
@@ -892,6 +893,7 @@ class GroupCoordinatorBaseRequestTest(cluster: ClusterInstance) {
892893
.setStandbyTasks(standbyTasks.asJava)
893894
.setWarmupTasks(warmupTasks.asJava)
894895
.setTopology(topology)
896+
.setProcessId(processId)
895897
).build(version)
896898

897899
// Send the request until receiving a successful response. There is a delay

0 commit comments

Comments
 (0)