Packages
brod
3.3.4
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
4
files changed
+6
additions
-6
deletions
| @@ -1,6 +1,6 @@ | |
| 1 1 | PROJECT = brod |
| 2 2 | PROJECT_DESCRIPTION = Kafka client library in Erlang |
| 3 | - PROJECT_VERSION = 3.3.3 |
| 3 | + PROJECT_VERSION = 3.3.4 |
| 4 4 | |
| 5 5 | DEPS = supervisor3 kafka_protocol |
| 6 6 | TEST_DEPS = docopt jsone meck proper |
| @@ -1,5 +1,5 @@ | |
| 1 1 | {<<"name">>,<<"brod">>}. |
| 2 | - {<<"version">>,<<"3.3.3">>}. |
| 2 | + {<<"version">>,<<"3.3.4">>}. |
| 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,"3.3.3"}, |
| 3 | + {vsn,"3.3.4"}, |
| 4 4 | {registered,[]}, |
| 5 5 | {applications,[kernel,stdlib,ssl,kafka_protocol,supervisor3]}, |
| 6 6 | {env,[]}, |
| @@ -916,12 +916,12 @@ get_committed_offsets(#state{ offset_commit_policy = commit_to_kafka_v2 | |
| 916 916 | Offset0 = kpro:find(offset, PartitionOffset), |
| 917 917 | Metadata = kpro:find(metadata, PartitionOffset), |
| 918 918 | EC = kpro:find(error_code, PartitionOffset), |
| 919 | - case EC =:= ?EC_UNKNOWN_TOPIC_OR_PARTITION of |
| 919 | + ?ESCALATE_EC(EC), |
| 920 | + %% Offset -1 in offset_fetch_response is an indicator of 'no-value' |
| 921 | + case EC =:= ?EC_NONE andalso Offset0 =:= -1 of |
| 920 922 | true -> |
| 921 | - %% EC_UNKNOWN_TOPIC_OR_PARTITION is kept for version 0 |
| 922 923 | Acc; |
| 923 924 | false -> |
| 924 | - ?ESCALATE_EC(EC), |
| 925 925 | Offset = maybe_upgrade_from_roundrobin_v1(Offset0, Metadata), |
| 926 926 | [{{Topic, Partition}, Offset} | Acc] |
| 927 927 | end |