kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Behrang Saeedzadeh <behran...@gmail.com>
Subject Does SinkTaskContext.timeout recall the connector's put method with the original collection of sink records?
Date Mon, 11 Sep 2017 05:56:07 GMT

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

  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message