具有 spring 集成 java 客户端的 maprsteam

Question

我正在寻找使用 maprstream 与 spring 集成的解决方案。我可以创建流和主题，也可以使用 stream:topic 组合来 consume/publish 消息。通过引用 link:

使用 Kafka 客户端

但是使用 Spring 集成努力 consume/publish 消息，并且看不到任何解释相同内容的示例程序。有人可以帮我解决这个问题吗？

Answer 1

spring-integration-kafka 2.0（通过spring-kafka 1.0）使用0.9 Kafka API.

见the compatibility matrix at the bottom of the project page。

尚未使用 MapR 进行测试。