brunoNetId opened a new issue, #3575:
URL: https://github.com/apache/camel-k/issues/3575
With the following use case as an example:
- process the daily Kafka messages produced in a topic
How could we run a Cron job with Camel K that connects to Kafka, consumes
the latest messages, and shuts down when no more messages are available (e.g.
setting a timeout).
I've created a proposed example (attached) where I use an aggregator with a
timeout. When the aggregator completes, let's say when no new messages arrive
in a specific window of time, a shutdown process trigger to stop the
CamelContext and the Java process.
Cron could see the process has stopped and schedule the next run the next
day or as per a Camel timer definition.
For simplicity, the example uses HTTP instead of Kafka.
[cron-example.tar.gz](https://github.com/apache/camel-k/files/9424194/cron-example.tar.gz)
--
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]
