spring-cloud-stream - Spring Cloud Stream Reactive - 在 react 流管道的情况下，哪个 kafka-binder 是合适的？

Question

我们在 Kafka 中使用 reactive spring cloud stream。关于使用正确的 Binder 有什么建议吗？哪个最适合响应式(Reactive)流水线？

1. spring-cloud-stream-binder-kafka
2. spring-cloud-stream-binder-kafka-streams

显然，如果我们得到 reactive-kafka-binder，我们会很高兴并希望。由于我们所有端到端的应用程序(源、处理器和接收器)都构建在 react 流管道上。

Reactive kafka will be the best suitable, since we are using entire pipeline as a reactive. To make the end-to-end pipeline reactive. Any plans of providing such reactive-kafka-binder in the spring?

为简单起见，目前我们使用 reactive spring cloud stream 和 spring-cloud-stream-binder-kafka 而不是 kafka-streams . 期待您的回答。非常感谢!

Answer 1

您正在使用正确的依赖项 - spring-cloud-stream-binder-kafka。

我建议使用来自 spring-cloud-stream-dependencies/spring- 的 spring-cloud-starter-stream-kafka 依赖cloud-dependencies-parent pom，不过。

    <dependencyManagement>

        <dependencies>

            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>${spring.cloud-version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>

        </dependencies>

    </dependencyManagement>

    <dependencies>

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-stream-kafka</artifactId>
        </dependency>

    </dependencies>