我是新来 Camel ,我需要听一个Kafka主题,因为我已经创建了一个消费者路线在 Camel ,这是成功上市的Kafka集群。现在我需要在新消息发布到kafka后立即动态添加路由。
用例-kafka生产者将cron详细信息作为kafka头发送==>camel route consumping到kafka集群==>一旦发布任何新消息,它将触发一个新路由(quartz route)并将cron表达式传递给quartz route。
如果你曾经遇到过这样的问题,请给予帮助。
谢谢迪帕克
我是新来 Camel ,我需要听一个Kafka主题,因为我已经创建了一个消费者路线在 Camel ,这是成功上市的Kafka集群。现在我需要在新消息发布到kafka后立即动态添加路由。
用例-kafka生产者将cron详细信息作为kafka头发送==>camel route consumping到kafka集群==>一旦发布任何新消息,它将触发一个新路由(quartz route)并将cron表达式传递给quartz route。
如果你曾经遇到过这样的问题,请给予帮助。
谢谢迪帕克
暂无答案!
目前还没有任何答案,快来回答吧!