Packages

brod

3.7.3
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

5 files changed
+16 additions
-14 deletions
  @@ -1,14 +1,14 @@
1 1 KAFKA_VERSION ?= 1.1
2 2 PROJECT = brod
3 3 PROJECT_DESCRIPTION = Kafka client library in Erlang
4 - PROJECT_VERSION = 3.7.2
4 + PROJECT_VERSION = 3.7.3
5 5
6 6 DEPS = supervisor3 kafka_protocol
7 7
8 8 ERLC_OPTS = -Werror +warn_unused_vars +warn_shadow_vars +warn_unused_import +warn_obsolete_guard +debug_info -Dbuild_brod_cli
9 9
10 - dep_supervisor3_commit = 1.1.7
11 - dep_kafka_protocol_commit = 2.2.2
10 + dep_supervisor3_commit = 1.1.8
11 + dep_kafka_protocol_commit = 2.2.4
12 12 dep_kafka_protocol = git https://github.com/klarna/kafka_protocol.git $(dep_kafka_protocol_commit)
13 13
14 14 EDOC_OPTS = preprocess, {macros, [{build_brod_cli, true}]}
  @@ -1,12 +1,12 @@
1 1 {<<"name">>,<<"brod">>}.
2 - {<<"version">>,<<"3.7.2">>}.
2 + {<<"version">>,<<"3.7.3">>}.
3 3 {<<"requirements">>,
4 4 #{<<"kafka_protocol">> =>
5 5 #{<<"app">> => <<"kafka_protocol">>,<<"optional">> => false,
6 - <<"requirement">> => <<"2.2.2">>},
6 + <<"requirement">> => <<"2.2.4">>},
7 7 <<"supervisor3">> =>
8 8 #{<<"app">> => <<"supervisor3">>,<<"optional">> => false,
9 - <<"requirement">> => <<"1.1.7">>}}}.
9 + <<"requirement">> => <<"1.1.8">>}}}.
10 10 {<<"app">>,<<"brod">>}.
11 11 {<<"maintainers">>,[<<"Ivan Dyachkov">>,<<"Zaiming Shi">>]}.
12 12 {<<"precompiled">>,false}.
  @@ -1,5 +1,5 @@
1 - {deps, [ {supervisor3, "1.1.7"}
2 - , {kafka_protocol, "2.2.2"}
1 + {deps, [ {supervisor3, "1.1.8"}
2 + , {kafka_protocol, "2.2.4"}
3 3 ]}.
4 4 {edoc_opts, [{preprocess, true}, {macros, [{build_brod_cli, true}]}]}.
5 5 {erl_opts, [warn_unused_vars,warn_shadow_vars,warn_unused_import,warn_obsolete_guard,debug_info]}.
  @@ -1,6 +1,6 @@
1 1 {application,brod,
2 2 [{description,"Apache Kafka Erlang client library"},
3 - {vsn,"3.7.2"},
3 + {vsn,"3.7.3"},
4 4 {registered,[]},
5 5 {applications,[kernel,stdlib,kafka_protocol,supervisor3]},
6 6 {env,[]},
  @@ -552,16 +552,18 @@ handle_ack(AckRef, #state{ generationId = GenerationId
552 552 , coordinator = Coordinator
553 553 } = State, CommitNow) ->
554 554 {Topic, Partition, Offset} = AckRef,
555 - Consumer = get_consumer({Topic, Partition}, Consumers),
556 - #consumer{consumer_pid = ConsumerPid} = Consumer,
557 - ok = consume_ack(ConsumerPid, Offset),
558 - case CommitNow of
559 - true ->
555 + case get_consumer({Topic, Partition}, Consumers) of
556 + #consumer{consumer_pid = ConsumerPid} = Consumer when CommitNow ->
557 + ok = consume_ack(ConsumerPid, Offset),
560 558 ok = do_commit_ack(Coordinator, GenerationId, Topic, Partition, Offset),
561 559 NewConsumer = Consumer#consumer{acked_offset = Offset},
562 560 NewConsumers = put_consumer(NewConsumer, Consumers),
563 561 State#state{consumers = NewConsumers};
562 + #consumer{consumer_pid = ConsumerPid} ->
563 + ok = consume_ack(ConsumerPid, Offset),
564 + State;
564 565 false ->
566 + %% Stale async-ack, discard.
565 567 State
566 568 end.