使用生產者消費者的卡夫卡和微服務

Question

我需要在我的微服務項目中使用Apache Kafka。我需要我的一個微服務來生成數據，另一個服務使用相同的數據。我怎樣才能讓卡夫卡在兩項服務之間做到相同

Answer 1

我建議你看看Spring Cloud Stream，因爲它完全符合你的需求。

從文檔：

框架構建消息驅動的微服務。 Spring Cloud Stream構建於Spring Boot基礎之上，以創建DevOps友好的微服務應用程序和Spring Integration，爲消息代理提供連接。 Spring Cloud Stream提供了消息代理的自定義配置，介紹了跨多箇中間件供應商的持久pub/sub語義，消費者組和分區的概念。這種自以爲是的配置爲創建流處理應用程序提供了基礎。

通過將@EnableBinding添加到主應用程序中，您可以立即連接到消息代理，並通過向方法添加@StreamListener，您將接收流處理的事件。