Packages
brod
3.7.2
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
6
files changed
+6
additions
-7
deletions
| @@ -1,7 +1,7 @@ | |
| 1 1 | KAFKA_VERSION ?= 1.1 |
| 2 2 | PROJECT = brod |
| 3 3 | PROJECT_DESCRIPTION = Kafka client library in Erlang |
| 4 | - PROJECT_VERSION = 3.7.1 |
| 4 | + PROJECT_VERSION = 3.7.2 |
| 5 5 | |
| 6 6 | DEPS = supervisor3 kafka_protocol |
| @@ -1,5 +1,5 @@ | |
| 1 1 | {<<"name">>,<<"brod">>}. |
| 2 | - {<<"version">>,<<"3.7.1">>}. |
| 2 | + {<<"version">>,<<"3.7.2">>}. |
| 3 3 | {<<"requirements">>, |
| 4 4 | #{<<"kafka_protocol">> => |
| 5 5 | #{<<"app">> => <<"kafka_protocol">>,<<"optional">> => false, |
| @@ -1,6 +1,6 @@ | |
| 1 1 | {application,brod, |
| 2 2 | [{description,"Apache Kafka Erlang client library"}, |
| 3 | - {vsn,"3.7.1"}, |
| 3 | + {vsn,"3.7.2"}, |
| 4 4 | {registered,[]}, |
| 5 5 | {applications,[kernel,stdlib,kafka_protocol,supervisor3]}, |
| 6 6 | {env,[]}, |
| @@ -474,11 +474,11 @@ update_avg_size(#state{ avg_bytes = AvgBytes | |
| 474 474 | update_avg_size(State#state{avg_bytes = NewAvgBytes}, Rest). |
| 475 475 | |
| 476 476 | err_op(?request_timed_out) -> retry; |
| 477 | - err_op(?unknown_topic_or_partition) -> stop; |
| 478 477 | err_op(?invalid_topic_exception) -> stop; |
| 479 478 | err_op(?offset_out_of_range) -> reset_offset; |
| 480 479 | err_op(?leader_not_available) -> reset_connection; |
| 481 480 | err_op(?not_leader_for_partition) -> reset_connection; |
| 481 | + err_op(?unknown_topic_or_partition) -> reset_connection; |
| 482 482 | err_op(_) -> restart. |
| 483 483 | |
| 484 484 | handle_fetch_error(#kafka_fetch_error{error_code = ErrorCode} = Error, |
| @@ -591,7 +591,7 @@ subscribe_partition(Client, Consumer) -> | |
| 591 591 | case brod_utils:is_pid_alive(Pid) of |
| 592 592 | true -> |
| 593 593 | Consumer; |
| 594 | - false when AckedOffset =/= LastOffset -> |
| 594 | + false when AckedOffset =/= LastOffset andalso LastOffset =/= ?undef -> |
| 595 595 | %% The last fetched offset is not yet acked, |
| 596 596 | %% do not re-subscribe now to keep it simple and slow. |
| 597 597 | %% Otherwise if we subscribe with {begin_offset, LastOffset + 1} |
Loading more files…