0

我目前正在尝试编写一个适配器,它将使用来自 ActiveMQ 的消息并将其发布到 Kafka。

我正在考虑使用 spring 集成来集成这两个消息传递系统。

我的问题是我的应用程序不会维护模型的注册表,许多应用程序将使用这些模型将记录发布到 activeMQ。我想接收这些 javax jms 消息并希望执行一些转换,例如将 jmscorrelationId 添加到 kafka 消息中。

此外,另一个要求是仅当 kafka 发送/发布成功时才向活动 mq 发送确认。

可以使用spring集成将ack发送回activemq吗?

spring 集成会是一个不错的选择吗?

请注意,我的技术架构师不赞成使用 Camel/Mule。此外,他不想使用 Kafka Connect,因为我打算使用 Kafka 连接源。

请建议。

4

1 回答 1

0

Spring Integration Kafka 扩展项目有一个发布的同步模式,它会阻塞线程,直到 Kafka 确认交付(或失败时抛出异常)。

JMS 入站网关可用于向 JMS 队列返回回复。

您可以在流中添加转换器(或其他)来修改消息。

于 2017-07-04T17:35:25.687 回答