Shreya21Mishra opened a new issue, #1672: URL: https://github.com/apache/camel-kafka-connector/issues/1672
Hi Let's say we 10 messages. After a timer of 5 mins elapses the 10 messages should get aggregated and written as one single message into the ADLS. We have an aggregation logic already in SMT. But camel.aggregation.timeout=5000 does not seem to work along with the aggregation logic. I also tested it out without the SMT customisation but that does not work as well. Could you please point out if I am missing anything -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
