Packages
brod
4.4.4
4.5.7
4.5.6
4.5.5
4.5.4
4.5.3
4.5.2
4.5.1
4.5.0
4.4.7
4.4.6
4.4.5
4.4.4
4.4.3
4.4.2
4.4.1
4.4.0
4.3.3
4.3.2
4.3.1
4.3.0
4.2.0
4.1.1
4.1.0
4.0.0
3.19.1
3.19.0
3.18.0
3.17.1
3.17.0
3.16.5
3.16.4
3.16.3
3.16.2
3.16.1
3.16.0
3.15.6
3.15.5
3.15.4
3.15.3
3.15.1
3.15.0
3.14.0
3.13.0
3.12.0
3.11.0
3.10.0
3.9.5
3.9.3
3.9.2
3.9.1
3.9.0
3.8.1
3.8.0
3.7.11
3.7.10
3.7.9
3.7.8
3.7.7
3.7.6
3.7.5
3.7.4
3.7.3
3.7.2
3.7.1
3.7.0
3.6.2
3.6.1
3.6.0
3.5.2
3.5.1
3.5.0
3.4.0
3.3.5
3.3.4
3.3.3
3.3.2
3.3.1
3.3.0
3.2.0
3.0.0
2.5.0
2.4.1
2.4.0
2.3.7
2.3.6
2.3.5
2.3.4
2.3.3
2.3.1
2.2.16
2.2.15
2.2.14
2.2.12
2.2.11
2.2.10
2.2.9
2.2.8
2.2.7
2.2.6
2.2.5
2.2.4
2.2.3
2.2.2
2.2.1
2.2.0
2.1.12
2.1.11
2.1.10
2.1.8
2.1.7
2.1.4
2.1.2
2.0.0
Apache Kafka Erlang client library
Current section
113 Versions
Jump to
Current section
113 Versions
Compare versions
3
files changed
+8
additions
-3
deletions
| @@ -24,4 +24,4 @@ | |
| 24 24 | [{<<"app">>,<<"kafka_protocol">>}, |
| 25 25 | {<<"optional">>,false}, |
| 26 26 | {<<"requirement">>,<<"4.2.6">>}]}]}. |
| 27 | - {<<"version">>,<<"4.4.3">>}. |
| 27 | + {<<"version">>,<<"4.4.4">>}. |
| @@ -1,6 +1,6 @@ | |
| 1 1 | {application,brod, |
| 2 2 | [{description,"Apache Kafka Erlang client library"}, |
| 3 | - {vsn,"4.4.3"}, |
| 3 | + {vsn,"4.4.4"}, |
| 4 4 | {registered,[]}, |
| 5 5 | {applications,[kernel,stdlib,kafka_protocol]}, |
| 6 6 | {env,[]}, |
| @@ -134,7 +134,12 @@ offset_fetch(Connection, GroupId, Topics0) -> | |
| 134 134 | -spec list_groups(conn()) -> kpro:req(). |
| 135 135 | list_groups(Connection) -> |
| 136 136 | Vsn = pick_version(list_groups, Connection), |
| 137 | - kpro:make_request(list_groups, Vsn, []). |
| 137 | + case Vsn >= 3 of |
| 138 | + true -> |
| 139 | + kpro:make_request(list_groups, Vsn, #{tagged_fields => []}); |
| 140 | + false -> |
| 141 | + kpro:make_request(list_groups, Vsn, []) |
| 142 | + end. |
| 138 143 | |
| 139 144 | %% @doc Make a `join_group' request. |
| 140 145 | -spec join_group(conn(), kpro:struct()) -> kpro:req(). |