2017-08-29 46 views
0

我正在寻找一个解决方案,使用maprstream与弹簧整合。我可以创建流和主题,也可以使用流:主题组合来消费/发布消息。通过参考link来使用卡夫卡客户端:maprsteam with spring integration java client

但是使用Spring集成努力消费/发布消息,并且看不到任何解释相同的示例程序。有人可以帮助我吗?

回答

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测试。

+1

另外,你应该确定你确实排除了'kafka-clients'的依赖关系,并且包含'0.9.0.0-mapr-1602'版本。 –

+0

谢谢加里和阿尔乔姆。以下版本适用于我。 spring-integration-kafka.version => 2.0.0,spring-kafka.version => 1.0.0 – kattoor