需要有从kafka读取事务路由->保留在db中->发布到MQ。
所有这一切都应该在一个事务中发生，如果 DB 或 Commit to MQ/JMS 失败，那么 kafka 消息不应该从主题中删除。
尝试查找camel文档但没有找到任何用例。 https://camel.apache.org/components/4.4.x/eips/transactional-client.html
请参阅camel-kafka 文档，其中有关于事务的部分： https://camel.apache.org/components/4.4.x/kafka-component.html#_kafka_transaction