Hello,

I'd like to propose a small KIP to add a new field to SinkRecord in order
to add support for topic-mutating SMTs (e.g. RegexRouter) to asynchronous
Sink Connectors (the ones that override preCommit for internal offset
tracking, like S3
<https://github.com/confluentinc/kafka-connect-storage-cloud/blob/master/kafka-connect-s3/src/main/java/io/confluent/connect/s3/S3SinkTask.java#L274>
).

Links:

- KIP-793: Sink Connectors: Support topic-mutating SMTs for async
connectors (preCommit users)
<https://cwiki.apache.org/confluence/x/fpFnCw>
- PR #11464 <https://github.com/apache/kafka/pull/11464>

Thanks,

Diego

Reply via email to