Packages
brod
4.4.0
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
6
files changed
+10
additions
-8
deletions
| @@ -23,5 +23,5 @@ | |
| 23 23 | [{<<"kafka_protocol">>, |
| 24 24 | [{<<"app">>,<<"kafka_protocol">>}, |
| 25 25 | {<<"optional">>,false}, |
| 26 | - {<<"requirement">>,<<"4.1.10">>}]}]}. |
| 27 | - {<<"version">>,<<"4.3.3">>}. |
| 26 | + {<<"requirement">>,<<"4.2.3">>}]}]}. |
| 27 | + {<<"version">>,<<"4.4.0">>}. |
| @@ -1,4 +1,4 @@ | |
| 1 | - {deps, [{kafka_protocol, "4.1.10"}]}. |
| 1 | + {deps, [{kafka_protocol, "4.2.3"}]}. |
| 2 2 | {project_plugins, [{rebar3_lint, "~> 3.2.5"}]}. |
| 3 3 | {edoc_opts, [{preprocess, true}]}. |
| 4 4 | {erl_opts, [warnings_as_errors, warn_unused_vars,warn_shadow_vars,warn_obsolete_guard,debug_info]}. |
| @@ -14,6 +14,8 @@ | |
| 14 14 | , {proper, "1.4.0"} |
| 15 15 | , {snappyer, "1.2.9"} |
| 16 16 | , {snabbkaffe, {git, "https://github.com/kafka4beam/snabbkaffe.git", {branch, "1.0.10"}}} |
| 17 | + , {lz4b, "0.0.11"} |
| 18 | + , {ezstd, "1.1.0"} |
| 17 19 | ]}, |
| 18 20 | {erl_opts, [warnings_as_errors, {d, build_brod_cli}]} |
| 19 21 | ]} |
| @@ -1,6 +1,6 @@ | |
| 1 1 | {application,brod, |
| 2 2 | [{description,"Apache Kafka Erlang client library"}, |
| 3 | - {vsn,"4.3.3"}, |
| 3 | + {vsn,"4.4.0"}, |
| 4 4 | {registered,[]}, |
| 5 5 | {applications,[kernel,stdlib,kafka_protocol]}, |
| 6 6 | {env,[]}, |
| @@ -241,7 +241,7 @@ | |
| 241 241 | {ok, partition()}). |
| 242 242 | -type partitioner() :: partition_fun() | random | hash. |
| 243 243 | -type produce_ack_cb() :: fun((partition(), offset()) -> _). |
| 244 | - -type compression() :: no_compression | gzip | snappy. |
| 244 | + -type compression() :: no_compression | gzip | snappy | lz4 | zstd. |
| 245 245 | -type call_ref() :: #brod_call_ref{}. %% A record with caller, callee, and ref. |
| 246 246 | -type produce_result() :: brod_produce_req_buffered |
| 247 247 | | brod_produce_req_acked. |
| @@ -139,8 +139,8 @@ lookup_vsn_range(Conn, API) -> | |
| 139 139 | %% Do not change range without verification. |
| 140 140 | supported_versions(API) -> |
| 141 141 | case API of |
| 142 | - produce -> {0, 5}; |
| 143 | - fetch -> {0, 7}; |
| 142 | + produce -> {0, 7}; |
| 143 | + fetch -> {0, 10}; |
| 144 144 | list_offsets -> {0, 2}; |
| 145 145 | metadata -> {0, 2}; |
| 146 146 | offset_commit -> {2, 2}; |
Loading more files…