OK, thank you for that. I looked at org.apache.kafka.connect.transforms.Transformation and org.apache.kafka.connect.source.SourceRecord, but am not discovering where the authenticated username (or Principal) might be available for the call to Transformation.apply()… or does Connect even support SSL and client certificate based authentication in the first place? If not, I think Connect may not be quite right for my use case.
— m@ > On 21/03/2017, at 4:59 PM, Hans Jespersen <h...@confluent.io> wrote: > > Nothing on the broker today but if you use Kafka Connect API in 0.10.2 and > above there is a pluggable interface called Transformations. > > See org.apache.kafka.connect.transforms in > https://kafka.apache.org/0102/javadoc/index.html?org/apache/kafka/connect > > Source Connector transformations happen before storage in the Kafka log and > Sink Connector transformations happen afterwards for consumers. > > -hans
