ryerraguntla commented on code in PR #4401:
URL: https://github.com/apache/iggy/pull/4401#discussion_r4180717309
##########
gateways/kafka/tests/consumer_group_tests.rs:
##########
@@ -1416,6 +1432,493 @@ async fn
given_a_transaction_key_type_when_finding_the_coordinator_should_return
assert_eq!(decoder.remaining(), 0);
}
+// ── DescribeGroups / ListGroups ─────────────────────────────────────────────
+
+async fn describe(state: &GatewayState, version: i16, groups: &[&str]) ->
DescribeResponse {
+ let body = build_describe_groups_request(version, groups, false);
+ let response = handle_request_bounded(state, API_KEY_DESCRIBE_GROUPS,
version, body)
+ .await
+ .expect_response("DescribeGroups must answer");
+ DescribeResponse::decode(version, response)
Review Comment:
fixed
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
