Packages
brod
3.3.5
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
5
files changed
+7
additions
-7
deletions
| @@ -1,6 +1,6 @@ | |
| 1 1 | PROJECT = brod |
| 2 2 | PROJECT_DESCRIPTION = Kafka client library in Erlang |
| 3 | - PROJECT_VERSION = 3.3.4 |
| 3 | + PROJECT_VERSION = 3.3.5 |
| 4 4 | |
| 5 5 | DEPS = supervisor3 kafka_protocol |
| 6 6 | TEST_DEPS = docopt jsone meck proper |
| @@ -10,7 +10,7 @@ ERLC_OPTS = -Werror +warn_unused_vars +warn_shadow_vars +warn_unused_import +war | |
| 10 10 | TEST_ERLC_OPTS = -Werror +warn_unused_vars +warn_shadow_vars +warn_unused_import +warn_obsolete_guard +debug_info |
| 11 11 | |
| 12 12 | dep_supervisor3_commit = 1.1.5 |
| 13 | - dep_kafka_protocol_commit = 1.1.1 |
| 13 | + dep_kafka_protocol_commit = 1.1.2 |
| 14 14 | dep_docopt = git https://github.com/zmstone/docopt-erl.git 0.1.3 |
| 15 15 | |
| 16 16 | ERTS_VSN = $(shell erl -noshell -eval 'io:put_chars(erlang:system_info(version)), halt()') |
| @@ -1,9 +1,9 @@ | |
| 1 1 | {<<"name">>,<<"brod">>}. |
| 2 | - {<<"version">>,<<"3.3.4">>}. |
| 2 | + {<<"version">>,<<"3.3.5">>}. |
| 3 3 | {<<"requirements">>, |
| 4 4 | #{<<"kafka_protocol">> => #{<<"app">> => <<"kafka_protocol">>, |
| 5 5 | <<"optional">> => false, |
| 6 | - <<"requirement">> => <<"1.1.1">>}, |
| 6 | + <<"requirement">> => <<"1.1.2">>}, |
| 7 7 | <<"supervisor3">> => #{<<"app">> => <<"supervisor3">>, |
| 8 8 | <<"optional">> => false, |
| 9 9 | <<"requirement">> => <<"1.1.5">>}}}. |
| @@ -1,4 +1,4 @@ | |
| 1 1 | {deps, [ {supervisor3, "1.1.5"} |
| 2 | - , {kafka_protocol, "1.1.1"} |
| 2 | + , {kafka_protocol, "1.1.2"} |
| 3 3 | ]}. |
| 4 4 | {erl_opts, [warn_unused_vars,warn_shadow_vars,warn_unused_import,warn_obsolete_guard,debug_info]}. |
| @@ -1,6 +1,6 @@ | |
| 1 1 | {application,brod, |
| 2 2 | [{description,"Apache Kafka Erlang client library"}, |
| 3 | - {vsn,"3.3.4"}, |
| 3 | + {vsn,"3.3.5"}, |
| 4 4 | {registered,[]}, |
| 5 5 | {applications,[kernel,stdlib,ssl,kafka_protocol,supervisor3]}, |
| 6 6 | {env,[]}, |
| @@ -918,7 +918,7 @@ get_committed_offsets(#state{ offset_commit_policy = commit_to_kafka_v2 | |
| 918 918 | EC = kpro:find(error_code, PartitionOffset), |
| 919 919 | ?ESCALATE_EC(EC), |
| 920 920 | %% Offset -1 in offset_fetch_response is an indicator of 'no-value' |
| 921 | - case EC =:= ?EC_NONE andalso Offset0 =:= -1 of |
| 921 | + case Offset0 =:= -1 of |
| 922 922 | true -> |
| 923 923 | Acc; |
| 924 924 | false -> |