是否有对 kafka 0.8.2.2 的弹簧支持？

Question

我想使用 spring 支持与 kafka 集成。服务器版本是 0.8.2.2，但我能找到的所有 spring 项目都使用更新的 kafka。甚至 spring-kafka-1.0.0 也使用 kafka 0.9.0.1。我读到 kafka 客户端不向后兼容。所以问题是：对于旧版 kafka 是否有任何 spring 支持，或者我必须获得官方 kafka 客户端并自己做？

Answer 1

Spring Cloud Stream 1.0.x 版本支持 kafka binder 和 kafka version 0.8.2.2。 Spring Integration Kafka1.3.x版本也使用Kafka0.8.2.2。

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