The flush interval is controlled by offset.flush.interval.ms, which is
the Interval at which to try committing offsets for tasks. You can find the
documentation for this config at
http://docs.confluent.io/2.0.1/connect/userguide.html#configuring-workers
-Liquan
On Fri, Apr 8, 2016 at 8:19 PM, vic
Hi,
Recently, I am working on kafka connector implement. According to the
connector sink task document, the connect platform invoke flush method
periodically, But the doc does not metition the flush interval.
I don't know the flush interval default value or Where we can set this
interval??
Be
