Apologies for the poor formatting on the quoted bits in the previous email.
On 2021/11/03 22:17:06 Diego Erdody wrote: > 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 >
