Hey y'all, please vote for KIP-416 by replying +1 to this thread. Right now, there is no way for a SourceConnector/Task to know:
- whether a record was successfully sent to Kafka, vs filtered out or skipped. - the downstream offsets and metadata of sent records KIP-416 proposes adding a recordLogged() callback for this purpose. https://cwiki.apache.org/confluence/display/KAFKA/KIP-416%3A+Notify+SourceTask+of+ACK%27d+offsets%2C+metadata Thanks! Ryanne
