java - 是否有对 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 Stream1.0.x版本支持 kafka binder 和 kafka version 0.8.2.2。Spring Integration Kafka1.3.x版本也使用 Kafka 0.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，这对您来说非常有用。如果您需要低级别的支持来管理您自己的分区指针和领导者选举，那么在这些部分上找到文档会有点困难。