Reputation: 14550
I'd like to use spring support to integrate with kafka. the server version is 0.8.2.2 but all the spring projects i could find uses newer kafka. even spring-kafka-1.0.0 uses kafka 0.9.0.1. and i read that kafka client's is not backward compatible. so the question is: is there any spring support for older kafka version or i have to get official kafka client and do it by myself?
Upvotes: 0
Views: 984
Reputation: 3093
You can use spring-integration 1.3.x with spring-integration-kafka and use the spring-integration-java-dsl to integrate with Kafka 0.8.2.2
E.g. if you use 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>
If you are using the high level API this will work pretty good for you. If you need low level support to manage your own partition pointers and leader election it will be a little bit more difficult to find documentation on those parts.
Upvotes: 0
Reputation: 4179
Spring Cloud Stream 1.0.x
versions supports kafka binder with kafka version 0.8.2.2
. Spring Integration Kafka 1.3.x
version also uses Kafka 0.8.2.2
.
Upvotes: 3