Packages
brod
3.14.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
13
files changed
+233
additions
-49
deletions
| @@ -14,7 +14,7 @@ | |
| 14 14 | <<"src/brod_kafka_request.erl">>,<<"src/brod_producer.erl">>, |
| 15 15 | <<"src/brod_producer_buffer.erl">>,<<"src/brod_producers_sup.erl">>, |
| 16 16 | <<"src/brod_sup.erl">>,<<"src/brod_topic_subscriber.erl">>, |
| 17 | - <<"src/brod_utils.erl">>]}. |
| 17 | + <<"src/brod_topic_subscriber_cb_fun.erl">>,<<"src/brod_utils.erl">>]}. |
| 18 18 | {<<"licenses">>,[<<"Apache License 2.0">>]}. |
| 19 19 | {<<"links">>,[{<<"Github">>,<<"https://github.com/klarna/brod">>}]}. |
| 20 20 | {<<"name">>,<<"brod">>}. |
| @@ -27,4 +27,4 @@ | |
| 27 27 | [{<<"app">>,<<"supervisor3">>}, |
| 28 28 | {<<"optional">>,false}, |
| 29 29 | {<<"requirement">>,<<"1.1.11">>}]}]}. |
| 30 | - {<<"version">>,<<"3.13.0">>}. |
| 30 | + {<<"version">>,<<"3.14.0">>}. |
| @@ -35,6 +35,12 @@ | |
| 35 35 | , node_id :: integer() |
| 36 36 | }). |
| 37 37 | |
| 38 | + -record(cbm_init_data, |
| 39 | + { committed_offsets :: brod_topic_subscriber:committed_offsets() |
| 40 | + , cb_fun :: brod_topic_subscriber:cb_fun() |
| 41 | + , cb_data :: term() |
| 42 | + }). |
| 43 | + |
| 38 44 | -type sasl_opt() :: {plain, User :: string() | binary(), |
| 39 45 | Pass :: string() | binary() | |
| 40 46 | fun(() -> string() | binary())} |
| @@ -2,7 +2,7 @@ | |
| 2 2 | , {kafka_protocol, "2.3.6"} |
| 3 3 | ]}. |
| 4 4 | {edoc_opts, [{preprocess, true}, {macros, [{build_brod_cli, true}]}]}. |
| 5 | - {erl_opts, [warn_unused_vars,warn_shadow_vars,warn_unused_import,warn_obsolete_guard,debug_info]}. |
| 5 | + {erl_opts, [warn_unused_vars,warn_shadow_vars,warn_obsolete_guard,debug_info]}. |
| 6 6 | {xref_checks, [undefined_function_calls, undefined_functions, |
| 7 7 | locals_not_used, deprecated_function_calls, |
| 8 8 | deprecated_functions]}. |
| @@ -2,7 +2,7 @@ IsRebar3 = erlang:function_exported(rebar3, main, 1), | |
| 2 2 | DocoptUrl = "https://github.com/zmstone/docopt-erl.git", |
| 3 3 | DocOptTag = "0.1.3", |
| 4 4 | DocoptDep = {docopt, {git, DocoptUrl, {branch, DocOptTag}}}, |
| 5 | - Snabbkaffe = {snabbkaffe, {git, "https://github.com/klarna/snabbkaffe", {tag, "0.5.0"}}}, |
| 5 | + Snabbkaffe = {snabbkaffe, {git, "https://github.com/klarna/snabbkaffe", {tag, "0.6.0"}}}, |
| 6 6 | Profiles = |
| 7 7 | {profiles, [ |
| 8 8 | {brod_cli, [ |
| @@ -1,6 +1,6 @@ | |
| 1 1 | {application,brod, |
| 2 2 | [{description,"Apache Kafka Erlang client library"}, |
| 3 | - {vsn,"3.13.0"}, |
| 3 | + {vsn,"3.14.0"}, |
| 4 4 | {registered,[]}, |
| 5 5 | {applications,[kernel,stdlib,kafka_protocol,supervisor3]}, |
| 6 6 | {env,[]}, |
Loading more files…