Hi all,

I've written a KIP to update the SinkTask abstract class to specify that
the `put` method will take ArrayList. I think this will greatly simplify
connector development, so you aren't limited to the simplest iterations. It
will also harden the ordering guarantees of the API.

Looking forward to the feedback!

https://cwiki.apache.org/confluence/display/KAFKA/KIP-502%3A+Connect+SinkTask.put%28...%29+to+specify+ArrayList%3CSinkRecord%3E+in+Signature

Cyrus

Reply via email to