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.connect.runtime.WorkerSourceTask)
[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.connect.runtime.WorkerSourceTask)
According to a recent thread here I first increased tasks.max to 32, that
did help, but I still see that error on some of the threads/tasks.
So I tried to set offset.flush.timeout.ms but it seems that MM2 does not
pick up this configuration.
What is exactly the configuration line I should use to set it, it is not
really obvious from the doc how to set such configurations?
Thanks,
Peter
