請原諒含糊不清,因為我正試圖用我所擁有的一點知識盡可能地清楚。
我們有一個 Kafka 集群,想法是有一個 Spring Boot 應用程式作為生產者、消費者和 Kafka 之間的橋梁。
我使用過簡單的 REST、CRUD 應用程式,在這些應用程式中,我基本上根據請求與服務器進行互動。
題:
如何在 Spring 和 Kafka 之間創建持久連接以發送和接收訊息?
協議重要嗎?
uj5u.com熱心網友回復:
Kafka 使用自己的二進制協議通過 TCP將訊息發布到主題,以便通過訂閱輪詢訊息。為了能夠從 Spring Boot 專案連接到 Kafka 集群,您可能需要使用spring-kafka它為此協議提供實作:
<dependency>
<groupId>org.springframework.kafka</groupId>
<artifactId>spring-kafka</artifactId>
<version>2.8.0</version>
</dependency>
發布者和消費者的極簡設定可以在官方spring-kafka 檔案中找到。
uj5u.com熱心網友回復:
我知道您想在 Kafka 主題上創建生產者和消費者。你檢查過https://www.baeldung.com/spring-cloud-stream
轉載請註明出處,本文鏈接:https://www.uj5u.com/caozuo/366955.html
