Packages
brod
2.2.11
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
+32
additions
-55
deletions
| @@ -1,6 +1,6 @@ | |
| 1 1 | PROJECT = brod |
| 2 2 | PROJECT_DESCRIPTION = Kafka client library in Erlang |
| 3 | - PROJECT_VERSION = 2.2.10 |
| 3 | + PROJECT_VERSION = 2.2.11 |
| 4 4 | |
| 5 5 | DEPS = supervisor3 kafka_protocol |
| @@ -1,5 +1,5 @@ | |
| 1 1 | {<<"name">>,<<"brod">>}. |
| 2 | - {<<"version">>,<<"2.2.10">>}. |
| 2 | + {<<"version">>,<<"2.2.11">>}. |
| 3 3 | {<<"requirements">>, |
| 4 4 | #{<<"kafka_protocol">> => #{<<"app">> => <<"kafka_protocol">>, |
| 5 5 | <<"optional">> => false, |
| @@ -1,6 +1,6 @@ | |
| 1 1 | {application,brod, |
| 2 2 | [{description,"Apache Kafka Erlang client library"}, |
| 3 | - {vsn,"2.2.10"}, |
| 3 | + {vsn,"2.2.11"}, |
| 4 4 | {registered,[]}, |
| 5 5 | {applications,[kernel,stdlib,ssl,kafka_protocol,supervisor3]}, |
| 6 6 | {env,[]}, |
| @@ -180,7 +180,11 @@ start_client(BootstrapEndpoints, ClientId) -> | |
| 180 180 | -spec start_client([endpoint()], brod_client_id(), client_config()) -> |
| 181 181 | ok | {error, any()}. |
| 182 182 | start_client(BootstrapEndpoints, ClientId, Config) -> |
| 183 | - brod_sup:start_client(BootstrapEndpoints, ClientId, Config). |
| 183 | + case brod_sup:start_client(BootstrapEndpoints, ClientId, Config) of |
| 184 | + ok -> ok; |
| 185 | + {error, {already_started, _Pid}} -> ok; |
| 186 | + {error, Reason} -> {error, Reason} |
| 187 | + end. |
| 184 188 | |
| 185 189 | %% @equiv stat_link_client(BootstrapEndpoints, brod_default_client) |
| 186 190 | -spec start_link_client([endpoint()]) -> {ok, pid()} | {error, any()}. |
| @@ -34,7 +34,7 @@ | |
| 34 34 | , del/2 |
| 35 35 | , get_caller/2 |
| 36 36 | , get_corr_id/1 |
| 37 | - , increment_corr_id/1 |
| 37 | + , increment_corr_id/1 |
| 38 38 | ]). |
| 39 39 | |
| 40 40 | -export_type([requests/0]). |
Loading more files…