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