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,这对您来说非常有用。如果您需要低级别支持来管理您自己的分区指针和领导者选举,那么找到有关这些部分的文档会有点困难。