如何在Spring mvc中使用Apache kafka？可能嗎？

Question

我是apache kafka的初學者，嘗試學習融合 - kafka - rest - utils，但是我很困惑我該如何使用它。

在搜索過程中，我發現這個文檔https://spring.io/blog/2015/04/15/using-apache-kafka-for-integration-and-data-processing-pipelines-with-spring

這是非常好的文件，但它並不能幫助我學會休息-utils的。

的融合卡夫卡的git的代碼休息utils的是

https://github.com/confluentinc/kafka-rest是演示如何使用休息卡夫卡。但我想知道確切的程序要更多地瞭解它。有一些簡單的解釋。任何人都可以建議我與我如何使用休息客戶端的一些鏈接。請指導我這一點。

這可能是一個愚蠢的問題，但我沒有其他選擇學習。

在此先感謝。

Answer 1

首先嚐試create a REST service using spring MVC保留kafka的東西放在一邊。

一旦您能夠運行'hello world'類的REST服務，然後選擇Kafka Docs。

請參閱有關如何創建kafka集羣的文檔，並運行缺省控制檯消費者和生產者程序來檢查您的集羣。

現在，編寫一個主要的java程序，並使用Kafka Clients API創建一個kafka生產者。請參閱其文檔。確保通過主程序發送的消息傳達給消費者。

現在，將這個主程序的內容注入rest服務中，以便在請求正文中傳遞的消息現在傳遞給kafka集羣並且可供消費者讀取。

希望它有幫助。