Packages
brod
3.5.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
Current section
113 Versions
Jump to
Current section
113 Versions
Compare versions
9
files changed
+100
additions
-27
deletions
| @@ -1,6 +1,6 @@ | |
| 1 1 | PROJECT = brod |
| 2 2 | PROJECT_DESCRIPTION = Kafka client library in Erlang |
| 3 | - PROJECT_VERSION = 3.4.0 |
| 3 | + PROJECT_VERSION = 3.5.0 |
| 4 4 | |
| 5 5 | DEPS = supervisor3 kafka_protocol |
| 6 6 | TEST_DEPS = docopt jsone meck proper |
| @@ -39,7 +39,7 @@ ifeq ($(BROD_CLI),true) | |
| 39 39 | endif |
| 40 40 | |
| 41 41 | ## Make app the default target |
| 42 | - ## To avoid building a relese when brod is used as a erlang.mk project's dependency |
| 42 | + ## To avoid building a release when brod is used as a erlang.mk project's dependency |
| 43 43 | app:: |
| 44 44 | |
| 45 45 | include erlang.mk |
| @@ -376,7 +376,7 @@ auth(Host :: string(), Sock :: gen_tcp:socket() | ssl:sslsocket(), | |
| 376 376 | ``` |
| 377 377 | |
| 378 378 | If authentication is successful - callback function should return an atom `ok`, otherwise - error tuple with reason description. |
| 379 | - For example, you can use `brod_gssapi' plugin (https://github.com/ElMaxo/brod_gssapi) for SASL GSSAPI authentication. |
| 379 | + For example, you can use `brod_gssapi` plugin (https://github.com/ElMaxo/brod_gssapi) for SASL GSSAPI authentication. |
| 380 380 | To use it - add it as dependency to your top level project that uses brod. |
| 381 381 | Then add `{sasl, {callback, brod_gssapi, {gssapi, Keytab, Principal}}}` to client config. |
| 382 382 | Keytab should be the keytab file path, and Principal should be a byte-list or binary string. |
| @@ -394,7 +394,7 @@ Topic = <<"topic">>. | |
| 394 394 | Partition = 0. |
| 395 395 | brod:get_metadata(Hosts). |
| 396 396 | brod:get_metadata(Hosts, [Topic]). |
| 397 | - brod:get_offsets(Hosts, Topic, Partition). |
| 397 | + brod:resolve_offset(Hosts, Topic, Partition). |
| 398 398 | brod:fetch(Hosts, Topic, Partition, 1). |
| 399 399 | ``` |
| @@ -1,5 +1,5 @@ | |
| 1 1 | {<<"name">>,<<"brod">>}. |
| 2 | - {<<"version">>,<<"3.4.0">>}. |
| 2 | + {<<"version">>,<<"3.5.0">>}. |
| 3 3 | {<<"requirements">>, |
| 4 4 | #{<<"kafka_protocol">> => |
| 5 5 | #{<<"app">> => <<"kafka_protocol">>,<<"optional">> => false, |
| @@ -44,7 +44,10 @@ | |
| 44 44 | , ref :: reference() |
| 45 45 | }). |
| 46 46 | |
| 47 | + -define(BROD_PRODUCE_UNKNOWN_OFFSET, -1). |
| 48 | + |
| 47 49 | -record(brod_produce_reply, { call_ref :: brod:call_ref() |
| 50 | + , base_offset :: brod:offset() |
| 48 51 | , result :: brod:produce_result() |
| 49 52 | }). |
| @@ -1,6 +1,6 @@ | |
| 1 1 | {application,brod, |
| 2 2 | [{description,"Apache Kafka Erlang client library"}, |
| 3 | - {vsn,"3.4.0"}, |
| 3 | + {vsn,"3.5.0"}, |
| 4 4 | {registered,[]}, |
| 5 5 | {applications,[kernel,stdlib,ssl,kafka_protocol,supervisor3]}, |
| 6 6 | {env,[]}, |
Loading more files…