Packages

wolff

1.6.0
4.2.1 4.2.0 4.1.11 4.1.10 4.1.9 4.1.8 4.1.7 4.1.6 4.1.5 4.1.4 4.1.3 4.1.2 4.1.1 4.1.0 4.0.13 4.0.12 4.0.11 4.0.10 4.0.9 4.0.8 4.0.7 4.0.6 4.0.5 4.0.4 4.0.3 4.0.2 4.0.1 4.0.0 3.0.4 3.0.3 2.0.0 1.10.4 1.10.2 1.10.1 1.10.0 1.9.1 1.7.7 1.7.6 1.7.4 1.7.1 1.6.4 1.6.1 1.6.0

Kafka's publisher

Current section

Files

Jump to
Readme
43 Versions
2 Dependencies
Dependants
Files
Activity
wolff include wolff.hrl
Raw

include/wolff.hrl 

-ifndef(WOLFF_HRL).

-define(WOLFF_HRL, true).



-define(conn_down(Reason), {down, Reason}).

-define(conn_error(Reason), {error, Reason}).

-define(leader_connection(Pid), {leader_connection, Pid}).

-define(UNKNOWN_OFFSET, -1).

-define(buffer_overflow_discarded, buffer_overflow_discarded).



%% Kafka has default batch size limit 1000012.

%% Since Kafka 2.4, it has been extended to 1048588.

%% We keep it backward compatible here.

-define(WOLFF_KAFKA_DEFAULT_MAX_MESSAGE_BYTES, 1000000).

-endif.