Merge pull request #486 from 3duard0/fix/describe_groups

fix: describe_groups schema
kafka4beam · Jan 13, 2022 · 6410360 · 6410360
2 parents cd08945 + 84640d0
commit 6410360
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/brod_utils.erl b/src/brod_utils.erl
@@ -504,7 +504,7 @@ list_groups(Endpoint, ConnCfg) ->
 describe_groups(CoordinatorEndpoint, ConnCfg, IDs) ->
   with_conn([CoordinatorEndpoint], ConnCfg,
     fun(Pid) ->
-        Req = kpro:make_request(describe_groups, 0, [{group_ids, IDs}]),
+        Req = kpro:make_request(describe_groups, 0, [{groups, IDs}]),
         request_sync(Pid, Req)
     end).