我目前正在尝试编写一个适配器,它将使用来自 ActiveMQ 的消息并将其发布到 Kafka。
我正在考虑使用 spring 集成来集成这两个消息传递系统。
我的问题是我的应用程序不会维护模型的注册表,许多应用程序将使用这些模型将记录发布到 activeMQ。我想接收这些 javax jms 消息并希望执行一些转换,例如将 jmscorrelationId 添加到 kafka 消息中。
此外,另一个要求是仅当 kafka 发送/发布成功时才向活动 mq 发送确认。
可以使用spring集成将ack发送回activemq吗?
spring 集成会是一个不错的选择吗?
请注意,我的技术架构师不赞成使用 Camel/Mule。此外,他不想使用 Kafka Connect,因为我打算使用 Kafka 连接源。
请建议。