You are viewing a plain text version of this content. The canonical link for it is here.

Posted to users@kafka.apache.org by Behrang Saeedzadeh <be...@gmail.com> on 2017/09/11 05:56:07 UTC

Does SinkTaskContext.timeout recall the connector's put method with the original collection of sink records?

Hi,

If a connector encounters a temporary error (e.g. exceeding throughput) and
it calls the timeout(long) method, would it get passed the same set of
records that had caused the call to the timeout(long) method or should it
internally keep track of these records?

Best regards,
Behrang Saeedzadeh