Spring 集成 - ActiveMQ 到 Kafka
Spring Integration - ActiveMQ to Kafka
我目前正在尝试编写一个适配器，它将使用来自 ActiveMQ 的消息并将其发布到 Kafka。
我正在考虑使用 spring 集成来集成这两个消息系统。
我的问题是我的应用程序不会维护模型的注册表，许多应用程序使用这些注册表将记录发布到 activeMQ。我想接收这些 javax jms 消息并想执行一些转换，比如将 jmscorrelationId 添加到 kafka 消息中。
此外，另一个要求是仅当 kafka send/publish 成功时才向活动 mq 发送确认。
可以使用 spring 集成将 ack 发送回 activemq 吗？
spring 整合会是一个好的选择吗？
请注意我的技术架构师不赞成使用 Camel/Mule。此外，他不想使用 Kafka Connect，因为我正计划使用 Kafka 连接源。
请推荐。
Spring 集成 Kafka 扩展项目有一个 sync mode 用于发布，它将阻塞线程直到 Kafka 确认交付（或在失败时抛出异常）。
JMS 入站网关可用于return对 JMS 队列的回复。
您可以在流程中添加转换器（或其他）来修改消息。
我目前正在尝试编写一个适配器，它将使用来自 ActiveMQ 的消息并将其发布到 Kafka。
我正在考虑使用 spring 集成来集成这两个消息系统。
我的问题是我的应用程序不会维护模型的注册表，许多应用程序使用这些注册表将记录发布到 activeMQ。我想接收这些 javax jms 消息并想执行一些转换，比如将 jmscorrelationId 添加到 kafka 消息中。
此外，另一个要求是仅当 kafka send/publish 成功时才向活动 mq 发送确认。
可以使用 spring 集成将 ack 发送回 activemq 吗？
spring 整合会是一个好的选择吗？
请注意我的技术架构师不赞成使用 Camel/Mule。此外，他不想使用 Kafka Connect，因为我正计划使用 Kafka 连接源。
请推荐。
Spring 集成 Kafka 扩展项目有一个 sync mode 用于发布，它将阻塞线程直到 Kafka 确认交付（或在失败时抛出异常）。
JMS 入站网关可用于return对 JMS 队列的回复。
您可以在流程中添加转换器（或其他）来修改消息。