THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block |
---|
transforms=tsRouter,insertKafkaCoordinates transforms.tsRouter.type=org.apache.kafka.transforms.TimestampRouter transforms.tsRouter.topic.format=${topic}-${timestamp} transforms.tsRouter.timestamp.format=yyyyMMdd transforms.insertKafkaCoordinates.type=org.apache.kafka.transforms.InsertInValue transforms.insertKafkaCoordinates.topic=kafka_topic transforms.insertKafkaCoordinates.partition=kafka_partition transforms.insertKafkaCoordinates.offset=kafka_offset |
It may make sense to internally model the full transformation chain as a single composite Transformation
.
Application
For source connectors, transformations are applied on results from SourceTask.poll()
.
...