a00d9f17b1
wolff-1.10.4 handles message_too_large error code from Kafka. It tries to split the too-large batch into single-call batches (for EMQX, one call batch is always one message), and retry. In case a single-call batch is too large, EMQX should increment a failure counter.
18 lines
656 B
Erlang
18 lines
656 B
Erlang
%% -*- mode: erlang; -*-
|
|
|
|
{erl_opts, [debug_info]}.
|
|
{deps, [
|
|
{wolff, {git, "https://github.com/kafka4beam/wolff.git", {tag, "1.10.4"}}},
|
|
{kafka_protocol, {git, "https://github.com/kafka4beam/kafka_protocol.git", {tag, "4.1.5"}}},
|
|
{brod_gssapi, {git, "https://github.com/kafka4beam/brod_gssapi.git", {tag, "v0.1.1"}}},
|
|
{brod, {git, "https://github.com/kafka4beam/brod.git", {tag, "3.16.8"}}},
|
|
{snappyer, "1.2.9"},
|
|
{emqx_connector, {path, "../../apps/emqx_connector"}},
|
|
{emqx_resource, {path, "../../apps/emqx_resource"}},
|
|
{emqx_bridge, {path, "../../apps/emqx_bridge"}}
|
|
]}.
|
|
|
|
{shell, [
|
|
{apps, [emqx_bridge_confluent]}
|
|
]}.
|