Feature: Flush destination every Nth record or every X seconds
Closed this issue · 3 comments
lovromazgon commented
Feature description
Right now Flush
is used only when a destination stops. If the destination is writing records asynchronously (i.e. destination implements WriteAsync
) the SDK should call Flush
repeatedly every Nth record or every X seconds (exact numbers to be determined when implementing behavior) so the developer does not have to implement this behavior themselves.
lovromazgon commented
Not sure if this is worth addressing if we are going to change the Destination
interface (see ConduitIO/conduit#434).
hariso commented
Not sure if this is worth addressing if we are going to change the
Destination
interface (see ConduitIO/conduit#434).
Agreed. 👍
lovromazgon commented
Closing in favor of ConduitIO/conduit#434