2016-11-22 80 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,這對你來說很好。如果您需要低級別的支持來管理您自己的分區指針和領導者選舉,那麼在這些部分上找到文檔將會有點困難。