Packages

brod

3.4.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

HexDocs

Current section

113 Versions

Jump to
Readme
113 Versions
2 Dependencies
Dependants
Files
Activity
Hide whitespace

Compare versions

8 files changed
+138 additions
-114 deletions
  @@ -1,6 +1,6 @@
1 1 PROJECT = brod
2 2 PROJECT_DESCRIPTION = Kafka client library in Erlang
3 - PROJECT_VERSION = 3.3.5
3 + PROJECT_VERSION = 3.4.0
4 4
5 5 DEPS = supervisor3 kafka_protocol
6 6 TEST_DEPS = docopt jsone meck proper
  @@ -1,12 +1,12 @@
1 1 {<<"name">>,<<"brod">>}.
2 - {<<"version">>,<<"3.3.5">>}.
2 + {<<"version">>,<<"3.4.0">>}.
3 3 {<<"requirements">>,
4 - #{<<"kafka_protocol">> => #{<<"app">> => <<"kafka_protocol">>,
5 - <<"optional">> => false,
6 - <<"requirement">> => <<"1.1.2">>},
7 - <<"supervisor3">> => #{<<"app">> => <<"supervisor3">>,
8 - <<"optional">> => false,
9 - <<"requirement">> => <<"1.1.5">>}}}.
4 + #{<<"kafka_protocol">> =>
5 + #{<<"app">> => <<"kafka_protocol">>,<<"optional">> => false,
6 + <<"requirement">> => <<"1.1.2">>},
7 + <<"supervisor3">> =>
8 + #{<<"app">> => <<"supervisor3">>,<<"optional">> => false,
9 + <<"requirement">> => <<"1.1.5">>}}}.
10 10 {<<"app">>,<<"brod">>}.
11 11 {<<"maintainers">>,[<<"Ivan Dyachkov">>,<<"Zaiming Shi">>]}.
12 12 {<<"precompiled">>,false}.
  @@ -1,6 +1,6 @@
1 1 {application,brod,
2 2 [{description,"Apache Kafka Erlang client library"},
3 - {vsn,"3.3.5"},
3 + {vsn,"3.4.0"},
4 4 {registered,[]},
5 5 {applications,[kernel,stdlib,ssl,kafka_protocol,supervisor3]},
6 6 {env,[]},
  @@ -171,7 +171,10 @@
171 171 | max_bytes
172 172 | max_wait_time
173 173 | sleep_timeout
174 - | prefetch_count.
174 + | prefetch_count
175 + | prefetch_bytes
176 + | offset_reset_policy
177 + | size_stat_window.
175 178 -type consumer_options() :: [{consumer_option(), integer()}].
176 179 -type consumer_config() :: brod_consumer:config().
177 180
  @@ -521,7 +524,7 @@ start_link_group_subscriber(Client, GroupId, Topics, GroupConfig,
521 524 %% @equiv brod_group_subscriber:start_link/8
522 525 -spec start_link_group_subscriber(
523 526 client(), group_id(), [topic()], group_config(),
524 - consumer_config(), message | message_type,
527 + consumer_config(), message | message_set,
525 528 module(), term()) ->
526 529 {ok, pid()} | {error, any()}.
527 530 start_link_group_subscriber(Client, GroupId, Topics, GroupConfig,
  @@ -350,7 +350,7 @@ handle_call({stop_consumer, Topic}, _From, State) ->
350 350 {reply, ok, State};
351 351 handle_call({get_group_coordinator, GroupId}, _From, State) ->
352 352 #state{config = Config} = State,
353 - Timeout = proplists:get_value(get_metadata_timout_seconds, Config,
353 + Timeout = proplists:get_value(get_metadata_timeout_seconds, Config,
354 354 ?DEFAULT_GET_METADATA_TIMEOUT_SECONDS),
355 355 {Result, NewState} =
356 356 do_get_group_coordinator(State, GroupId, timer:seconds(Timeout)),
  @@ -543,7 +543,7 @@ do_get_metadata(Topic, #state{ client_id = ClientId
543 543 _ -> [Topic]
544 544 end,
545 545 Request = brod_kafka_request:metadata_request(SockPid, Topics),
546 - Timeout = proplists:get_value(get_metadata_timout_seconds, Config,
546 + Timeout = proplists:get_value(get_metadata_timeout_seconds, Config,
547 547 ?DEFAULT_GET_METADATA_TIMEOUT_SECONDS),
548 548 {Result, NewState} = request_sync(State, Request, timer:seconds(Timeout)),
549 549 case Result of
Loading more files…