kafka 0.8.2.2 有 spring 支持吗?
Is there any spring support for kafka 0.8.2.2?
我想使用 spring 支持与 kafka 集成。服务器版本是 0.8.2.2,但我能找到的所有 spring 项目都使用更新的 kafka。甚至 spring-kafka-1.0.0 使用 kafka 0.9.0.1。我读到 kafka 客户端不向后兼容。所以问题是:是否有 spring 支持较旧的 kafka 版本,或者我必须获得官方的 kafka 客户端并自己完成?
Spring Cloud Stream 1.0.x
版本支持 kafka 版本 0.8.2.2
的 kafka binder。 Spring 集成Kafka 1.3.x
版本也使用Kafka 0.8.2.2
.
您可以将 spring-integration 1.3.x 与 spring-integration-kafka 一起使用,并使用 spring-integration-java-dsl与 Kafka 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,这对您来说非常有用。如果您需要低级别支持来管理您自己的分区指针和领导者选举,那么找到有关这些部分的文档会有点困难。
我想使用 spring 支持与 kafka 集成。服务器版本是 0.8.2.2,但我能找到的所有 spring 项目都使用更新的 kafka。甚至 spring-kafka-1.0.0 使用 kafka 0.9.0.1。我读到 kafka 客户端不向后兼容。所以问题是:是否有 spring 支持较旧的 kafka 版本,或者我必须获得官方的 kafka 客户端并自己完成?
Spring Cloud Stream 1.0.x
版本支持 kafka 版本 0.8.2.2
的 kafka binder。 Spring 集成Kafka 1.3.x
版本也使用Kafka 0.8.2.2
.
您可以将 spring-integration 1.3.x 与 spring-integration-kafka 一起使用,并使用 spring-integration-java-dsl与 Kafka 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,这对您来说非常有用。如果您需要低级别支持来管理您自己的分区指针和领导者选举,那么找到有关这些部分的文档会有点困难。