oscerd commented on issue #1347: URL: https://github.com/apache/camel-kafka-connector/issues/1347#issuecomment-1077289681
No, it won't help. If you need to have different keyName for different customers, you'll need to provide the customer name dynamically. The only way to do that, is enriching the Kafka record in your topic with some headers like customerName and something like interval. Once your sink connector will start to consume the record from kafka, the header will be used to form the name. The other solution is having a connector for each customer. An SMT is Single Message Transformation, before the message reaches the sink connector, the SMT will join the game and you'll be able to modify the record and add more data or manipulate the current record. There are many examples if you search. I don't see other way except using headers or creating an SMT. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org