Packages
brod
4.4.7
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
4
files changed
+9
additions
-6
deletions
| @@ -23,5 +23,5 @@ | |
| 23 23 | [{<<"kafka_protocol">>, |
| 24 24 | [{<<"app">>,<<"kafka_protocol">>}, |
| 25 25 | {<<"optional">>,false}, |
| 26 | - {<<"requirement">>,<<"4.2.8">>}]}]}. |
| 27 | - {<<"version">>,<<"4.4.6">>}. |
| 26 | + {<<"requirement">>,<<"4.3.0">>}]}]}. |
| 27 | + {<<"version">>,<<"4.4.7">>}. |
| @@ -1,4 +1,4 @@ | |
| 1 | - {deps, [{kafka_protocol, "4.2.8"}]}. |
| 1 | + {deps, [{kafka_protocol, "4.3.0"}]}. |
| 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]}. |
| @@ -1,6 +1,6 @@ | |
| 1 1 | {application,brod, |
| 2 2 | [{description,"Apache Kafka Erlang client library"}, |
| 3 | - {vsn,"4.4.6"}, |
| 3 | + {vsn,"4.4.7"}, |
| 4 4 | {registered,[]}, |
| 5 5 | {applications,[kernel,stdlib,kafka_protocol]}, |
| 6 6 | {env,[]}, |
| @@ -373,8 +373,11 @@ handle_cast(_Cast, State) -> | |
| 373 373 | %% Handling all non call/cast messages |
| 374 374 | %% @end |
| 375 375 | %%-------------------------------------------------------------------- |
| 376 | - handle_info({'EXIT', Pid, _Reason}, #state{coordinator = Pid} = State) -> |
| 377 | - {stop, {shutdown, coordinator_failure}, State#state{coordinator = undefined}}; |
| 376 | + handle_info({'EXIT', Pid, Reason}, #state{coordinator = Pid} = State) -> |
| 377 | + %% Coordinator is owned by self and never explictly shutdown, |
| 378 | + %% so there is no 'normal' exit, hence the warning level log. |
| 379 | + ?BROD_LOG_WARNING("Coordinator EXIT:~p", [Reason]), |
| 380 | + {stop, {shutdown, coordinator_failure}, State#state{coordinator = undefined}}; |
| 378 381 | handle_info({'EXIT', Pid, Reason}, State) -> |
| 379 382 | case [TP || {TP, Pid1} <- maps:to_list(State#state.workers), Pid1 =:= Pid] of |
| 380 383 | [TopicPartition | _] -> |