Packages
brod
3.7.6
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
+8
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.5 |
| 4 | + PROJECT_VERSION = 3.7.6 |
| 5 5 | |
| 6 6 | DEPS = supervisor3 kafka_protocol |
| @@ -1,5 +1,5 @@ | |
| 1 1 | {<<"name">>,<<"brod">>}. |
| 2 | - {<<"version">>,<<"3.7.5">>}. |
| 2 | + {<<"version">>,<<"3.7.6">>}. |
| 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.5"}, |
| 3 | + {vsn,"3.7.6"}, |
| 4 4 | {registered,[]}, |
| 5 5 | {applications,[kernel,stdlib,kafka_protocol,supervisor3]}, |
| 6 6 | {env,[]}, |
| @@ -168,6 +168,8 @@ | |
| 168 168 | -type value() :: undefined %% no value, transformed to <<>> |
| 169 169 | | iodata() %% single value |
| 170 170 | | {msg_ts(), binary()} %% one message with timestamp |
| 171 | + | [?KV(key(), value())] %% backward compatible |
| 172 | + | [?TKV(msg_ts(), key(), value())] %% backward compatible |
| 171 173 | | kpro:msg_input() %% one magic v2 message |
| 172 174 | | kpro:batch_input(). %% maybe nested batch |
| @@ -489,7 +489,7 @@ handle_fetch_error(#kafka_fetch_error{error_code = ErrorCode} = Error, | |
| 489 489 | } = State) -> |
| 490 490 | case err_op(ErrorCode) of |
| 491 491 | reset_connection -> |
| 492 | - error_logger:info_msg("Fetch error ~p-~p: ~p", |
| 492 | + error_logger:info_msg("Fetch error ~s-~p: ~p", |
| 493 493 | [Topic, Partition, ErrorCode]), |
| 494 494 | %% The current connection in use is not connected to the partition leader, |
| 495 495 | %% so we dereference and demonitor the connection pid, but leave it alive, |
| @@ -506,7 +506,7 @@ handle_fetch_error(#kafka_fetch_error{error_code = ErrorCode} = Error, | |
| 506 506 | {noreply, maybe_send_fetch_request(State)}; |
| 507 507 | stop -> |
| 508 508 | ok = cast_to_subscriber(Subscriber, Error), |
| 509 | - error_logger:error_msg("Consumer ~p-~p shutdown\nReason: ~p", |
| 509 | + error_logger:error_msg("Consumer ~s-~p shutdown\nReason: ~p", |
| 510 510 | [Topic, Partition, ErrorCode]), |
| 511 511 | {stop, normal, State}; |
| 512 512 | reset_offset -> |
Loading more files…