如何通过 Spring Boot Web 应用程序创建到 Kafka 的持久连接答案

【问题标题】：How to create a persistent connection to Kafka through Spring Boot web application如何通过 Spring Boot Web 应用程序创建到 Kafka 的持久连接
【发布时间】：2022-01-04 16:53:08
【问题描述】：

请原谅歧义，因为我试图尽可能清楚地了解我所拥有的知识。

我们有一个 Kafka 集群，其想法是让 Spring Boot 应用程序充当生产者、消费者和 Kafka 之间的桥梁。

我使用过简单的 REST、CRUD 应用程序，在这些应用程序中，我基本上是根据请求与服务器交互。

问题：

如何在 Spring 和 Kafka 之间创建持久连接以发送和接收消息？

协议重要吗？

【问题讨论】：

标签： java spring spring-boot apache-kafka

【解决方案1】：

Kafka 使用自己的binary protocol over TCP 将消息发布到主题以轮询带有订阅的消息。为了能够从 Spring Boot 项目连接到 Kafka 集群，您可能需要使用spring-kafka，它提供了此协议的实现：

<dependency>
  <groupId>org.springframework.kafka</groupId>
  <artifactId>spring-kafka</artifactId>
  <version>2.8.0</version>
</dependency>

发布者和消费者的极简设置可以在官方spring-kafka docs 中找到。

【讨论】：

【解决方案2】：

我了解您希望在 Kafka 主题上创建生产者和消费者。你查过https://www.baeldung.com/spring-cloud-stream

【讨论】：