2016-11-22 168 views
0

我想使用弹簧支持与kafka集成。服务器版本是0.8.2.2,但我可以找到的所有春季项目都使用较新的kafka。甚至spring-kafka-1.0.0使用kafka 0.9.0.1。我读到卡夫卡客户端不是向后兼容的。所以问题是:是否有任何春季支持老卡夫卡版本,或者我必须得到官方卡夫卡客户端,并自己做?有没有kafka 0.8.2.2的spring支持?

回答

3

Spring Cloud Stream 1.0.x版本支持kafka版本的kafka活页夹0.8.2.2。春季整合卡夫卡1.3.x版本也使用卡夫卡0.8.2.2

+0

谢谢。 Spring集成'1.3.x'使用'0.8.2.1',但AFAIK可以安全地碰撞:https://github.com/spring-projects/spring-integration-kafka/tree/v1.3.0.RELEASE,但是我找不到有关spring-cloud-stream文档中版本的信息:http://docs.spring.io/spring-cloud-stream/docs/1.0.3.RELEASE/reference/htmlsingle/您能提供任何链接吗? – piotrek

+0

我没有看到它在该文档中明确指定,因为那时我们只支持0.8.x.x.你可以在这里看到版本:https://github.com/spring-cloud/spring-cloud-stream/blob/1.0.x/spring-cloud-stream-binders/spring-cloud-stream-binder-kafka/ pom.xml的#L17 –

0

你可以使用Spring的集成1.3.x的带弹簧集成 - 卡夫卡和使用弹簧集成的Java-DSL与卡夫卡0.8.2.2

例如整合如果你使用maven:

<dependency> 
     <groupId>org.springframework.integration</groupId> 
     <artifactId>spring-integration-java-dsl</artifactId> 
     <version>1.1.2.RELEASE</version> 
    </dependency> 
    <dependency> 
     <groupId>org.springframework.integration</groupId> 
     <artifactId>spring-integration-kafka</artifactId> 
     <version>1.3.0.RELEASE</version> 
    </dependency> 

如果你使用的是高级API,这对你来说很好。如果您需要低级别的支持来管理您自己的分区指针和领导者选举,那么在这些部分上找到文档将会有点困难。