Spring集成-ActiveMQ到Kafka
我目前正在尝试编写一个适配器，它将使用来自ActiveMQ的消息并将其发布到Kafka。
我正在考虑使用Spring集成来集成这两个消息传递系统。
我的问题是，我的应用程序不会维护模型的注册表，许多应用程序将使用该注册表将记录发布到activeMQ。我想接收这些javax-jms消息，并想执行一些转换，比如将jmscorrelationId添加到kafka消息中。
另外，另一个要求是仅当kafka发送/发布成功时才向活动mq发送确认。
ack可以使用Spring集成发送回active emq吗？
spring集成是一个好的选择吗？
请注意，我的技术架构师不赞成使用骆驼/骡子。此外，他不想使用Kafka连接，因为我计划使用Kafka连接源。
请建议。
共有1个答案
Spring IntegrKafka扩展项目有一个用于发布的同步模式，它将阻塞线程，直到Kafka确认交付（或在失败时抛出异常）。
JMS入站网关可用于向JMS队列返回回复。
您可以在流中添加转换器（或其他任何东西）来修改消息。
-
在我们的应用程序中，我们使用Spring与ActiveMQ集成。我们面临一个问题，例如每当ActiveMQ服务器关闭时，应用程序都会抛出： 你能建议如何让我的应用程序在ActiveMQ关闭的情况下运行吗 请在下面找到ActiveMQ配置：
-
本文向大家介绍如何集成 Spring Boot 和 ActiveMQ？相关面试题，主要包含被问及如何集成 Spring Boot 和 ActiveMQ？时的应答技巧和注意事项，需要的朋友参考一下 对于集成 Spring Boot 和 ActiveMQ，我们使用 spring-boot-starter-activemq 依赖关系。 它只需要很少的配置，并且不需要样板代码。
-
我的公司目前正在研究Thrift和ActiveMQ的集成。我们希望建立一个独立于语言的服务层，该服务层运行在单个http服务器上，每个thrift服务都能够通过ActiveMQ与其他thrift服务通信。到目前为止，我还没有找到任何其他人试图实施这一点。我很好奇其他人会如何实现这一点，以及是否有这样做的文档。 当前原型使用一个简单的python服务器来托管各种备用服务。在每个服务调用（即更新设置）
-
我正在尝试将我的应用程序与JMS队列集成（使用ActiveMQ）。我使用Spring集成作为集成组件。我们希望有连池。已将'maxContopt消费者'作为100提供给'DefaultMessageListenerContainer'。 问题是，一旦从队列中读取了所有消息，“消费者数量”仍为100（如ActiveMq控制台上所示）。当我们在数据库中使用连接池（通过JNDI）时，一旦不再需要连接，它
-
目标 我想发送一个消息到一个主题，我将处理稍后与客户机应用程序。为此，我使用Spring Boot和Spring Integration Java DSL及其JMS模块。作为消息代理，我使用本机ActiveMQ Artemis。 这是我的设置 作为ActiveMQ Artemis服务器，我使用具有默认配置的Vromero/Artemis(2.6.0)docker映像。 问题所在 在producer
-
如果发生异常，ActiveMQ broker不会相应地重新传递消息。 当我使用进行简单的集成测试时，JMS消息会被重新传递，即可以实现重试机制 如何用ActiveMQ为Tomcat实现同样的功能？