我目前正在尝试编写一个适配器，它将使用来自activemq的消息并将其发布到kafka。
我正在考虑使用spring集成来集成这两个消息传递系统。
我的问题是，我的应用程序不会维护模型的注册表，许多应用程序将使用这些模型将记录发布到activemq。我想接收这些javaxjms消息并执行一些转换，比如将jmscorrelationid添加到kafka消息中。
另外，另一个要求是仅当kafka发送/发布成功时才向活动mq发送确认。
可以使用spring集成将ack发送回activemq吗？
spring集成是一个好的选择吗？
请注意，我的技术架构师不赞成使用camel/mule。另外，他不想使用Kafka连接，因为我正计划使用Kafka连接源代码。
请建议。