Packages
brod
4.4.1
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
7
files changed
+34
additions
-32
deletions
| @@ -23,5 +23,5 @@ | |
| 23 23 | [{<<"kafka_protocol">>, |
| 24 24 | [{<<"app">>,<<"kafka_protocol">>}, |
| 25 25 | {<<"optional">>,false}, |
| 26 | - {<<"requirement">>,<<"4.2.3">>}]}]}. |
| 27 | - {<<"version">>,<<"4.4.0">>}. |
| 26 | + {<<"requirement">>,<<"4.2.5">>}]}]}. |
| 27 | + {<<"version">>,<<"4.4.1">>}. |
| @@ -1,4 +1,4 @@ | |
| 1 | - {deps, [{kafka_protocol, "4.2.3"}]}. |
| 1 | + {deps, [{kafka_protocol, "4.2.5"}]}. |
| 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]}. |
| @@ -7,14 +7,13 @@ | |
| 7 7 | deprecated_functions]}. |
| 8 8 | {profiles, [ |
| 9 9 | {test, [ |
| 10 | - {deps, [ {docopt, {git, "https://github.com/zmstone/docopt-erl.git", {tag, "0.1.3"}}} |
| 11 | - , {hut, "1.3.0"} |
| 10 | + {deps, [ {hut, "1.3.0"} |
| 12 11 | , {jsone, "1.7.0"} |
| 13 12 | , {meck, "0.9.2"} |
| 14 | - , {proper, "1.4.0"} |
| 13 | + , {proper, "1.5.0"} |
| 15 14 | , {snappyer, "1.2.9"} |
| 16 15 | , {snabbkaffe, {git, "https://github.com/kafka4beam/snabbkaffe.git", {branch, "1.0.10"}}} |
| 17 | - , {lz4b, "0.0.11"} |
| 16 | + , {lz4b, "0.0.13"} |
| 18 17 | , {ezstd, "1.1.0"} |
| 19 18 | ]}, |
| 20 19 | {erl_opts, [warnings_as_errors, {d, build_brod_cli}]} |
| @@ -41,7 +40,6 @@ | |
| 41 40 | , {api_reference, false} |
| 42 41 | ]}. |
| 43 42 | {hex, [{doc, ex_doc}]}. |
| 44 | - {escript_incl_apps, [docopt, brod]}. |
| 45 43 | {ct_opts, [{enable_builtin_hooks, false}]}. |
| 46 44 | {dialyzer, [{warnings, [unknown]}]}. |
| 47 45 | {cover_enabled, true}. |
| @@ -1,6 +1,6 @@ | |
| 1 1 | {application,brod, |
| 2 2 | [{description,"Apache Kafka Erlang client library"}, |
| 3 | - {vsn,"4.4.0"}, |
| 3 | + {vsn,"4.4.1"}, |
| 4 4 | {registered,[]}, |
| 5 5 | {applications,[kernel,stdlib,kafka_protocol]}, |
| 6 6 | {env,[]}, |
| @@ -61,6 +61,7 @@ | |
| 61 61 | , handle_call/3 |
| 62 62 | , handle_cast/2 |
| 63 63 | , handle_info/2 |
| 64 | + , handle_continue/2 |
| 64 65 | , init/1 |
| 65 66 | , terminate/2 |
| 66 67 | ]). |
| @@ -344,15 +345,14 @@ init({BootstrapEndpoints, ClientId, Config}) -> | |
| 344 345 | erlang:process_flag(trap_exit, true), |
| 345 346 | Tab = ets:new(?ETS(ClientId), |
| 346 347 | [named_table, protected, {read_concurrency, true}]), |
| 347 | - self() ! init, |
| 348 348 | {ok, #state{ client_id = ClientId |
| 349 349 | , bootstrap_endpoints = BootstrapEndpoints |
| 350 350 | , config = Config |
| 351 351 | , workers_tab = Tab |
| 352 | - }}. |
| 352 | + }, {continue, init}}. |
| 353 353 | |
| 354 354 | %% @private |
| 355 | - handle_info(init, State0) -> |
| 355 | + handle_continue(init, State0) -> |
| 356 356 | Endpoints = State0#state.bootstrap_endpoints, |
| 357 357 | State1 = ensure_metadata_connection(State0), |
| 358 358 | {ok, ProducersSupPid} = brod_producers_sup:start_link(), |
| @@ -361,7 +361,9 @@ handle_info(init, State0) -> | |
| 361 361 | , producers_sup = ProducersSupPid |
| 362 362 | , consumers_sup = ConsumersSupPid |
| 363 363 | }, |
| 364 | - {noreply, State}; |
| 364 | + {noreply, State}. |
| 365 | + |
| 366 | + %% @private |
| 365 367 | handle_info({'EXIT', Pid, Reason}, #state{ client_id = ClientId |
| 366 368 | , producers_sup = Pid |
| 367 369 | } = State) -> |
| @@ -164,7 +164,7 @@ | |
| 164 164 | %% |
| 165 165 | %% <li>`message_type': The type of message that is going to be handled |
| 166 166 | %% by the callback module. Can be either message or message set. |
| 167 | - %% Optional, defaults to `message'</li> |
| 167 | + %% Optional, defaults to `message_set'</li> |
| 168 168 | %% |
| 169 169 | %% <li>`init_data': The `term()' that is going to be passed to |
| 170 170 | %% `CbModule:init/2' when initializing the subscriber. Optional, |
Loading more files…