如何通过 Spring 引导 Web 应用程序创建与 Kafka 的持久连接
How to create a persistent connection to Kafka through Spring Boot web application
请原谅我的歧义，因为我试图用我所掌握的少量知识尽可能清楚。
我们有一个 Kafka 集群，我们的想法是有一个 Spring 引导应用程序作为生产者、消费者和 Kafka 之间的桥梁。
我使用过简单的 REST、CRUD 应用程序，在这些应用程序中，我基本上是根据请求与服务器进行交互。
问题：
如何在 Spring 和 Kafka 之间创建持久连接以发送和接收消息？
协议重要吗？
我了解到您想在 Kafka 主题上创建生产者和消费者。你检查过了吗https://www.baeldung.com/spring-cloud-stream
Kafka 使用自己的 binary protocol over TCP 将消息发布到主题，以便通过订阅轮询消息。
为了能够从 Spring 引导项目连接到 Kafka 集群，您可能需要使用 spring-kafka，它提供了此协议的实现：
<dependency>
<groupId>org.springframework.kafka</groupId>
<artifactId>spring-kafka</artifactId>
<version>2.8.0</version>
</dependency>
发布者和消费者的极简设置可以在官方文件中找到spring-kafka docs。
请原谅我的歧义，因为我试图用我所掌握的少量知识尽可能清楚。
我们有一个 Kafka 集群，我们的想法是有一个 Spring 引导应用程序作为生产者、消费者和 Kafka 之间的桥梁。
我使用过简单的 REST、CRUD 应用程序，在这些应用程序中，我基本上是根据请求与服务器进行交互。
问题：
如何在 Spring 和 Kafka 之间创建持久连接以发送和接收消息？
协议重要吗？
我了解到您想在 Kafka 主题上创建生产者和消费者。你检查过了吗https://www.baeldung.com/spring-cloud-stream
Kafka 使用自己的 binary protocol over TCP 将消息发布到主题，以便通过订阅轮询消息。
为了能够从 Spring 引导项目连接到 Kafka 集群，您可能需要使用 spring-kafka，它提供了此协议的实现：
<dependency>
<groupId>org.springframework.kafka</groupId>
<artifactId>spring-kafka</artifactId>
<version>2.8.0</version>
</dependency>
发布者和消费者的极简设置可以在官方文件中找到spring-kafka docs。