conduktor.io ↗

KIP-502 — Connect SinkTask.put(...) to specify ArrayList<SinkRecord> in Signature

Discussion Connect

Proposes changing `SinkTask.put(Collection<SinkRecord>)` to `SinkTask.put(List<SinkRecord>)` to expose the full `List` interface to connector implementors. The `Collection` type in the current signature denies connector developers access to index-based access, `subList()`, and other `List`-specific methods that simplify batch processing logic.

Details

AuthorCyrus Vafadari
StatusDiscussion
JIRAKAFKA-8749
WikiView on Apache Wiki
Created2019-08-03
Last Modified2019-09-24
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.