I figured it out.
The correct config is:
my_cluster_name.offset.flush.timeout.ms = 15000
Peter
On Thu, 16 Jan 2020 at 16:48, Péter Sinóros-Szabó <
peter.sinoros-sz...@transferwise.com> wrote:
> Hey,
>
> running MM2 that tried to process its backlog of 1 week just after it was
> started.
>
> I s
Hey,
running MM2 that tried to process its backlog of 1 week just after it was
started.
I see these in the logs:
[2020-01-16 13:07:30,985] ERROR
WorkerSourceTask{id=MirrorSourceConnector-0} Failed to flush, timed out
while waiting for producer to flush outstanding 4112 messages
(org.apache.kafka
