2017-10-18 88 views
-1

我想將現有的應用程序與Kafka集成。將現有的應用程序接口與Kafka集成

該應用程序不受我控制,所以我無法改變它的通信方式。應用程序將JSON請求發送到REST API後端。

如何在不改變代碼的情況下在應用程序及其後端之間添加Kafka?

+1

JSON請求是其中作爲卡夫卡使用它自己的協議進行通信的HTTP請求。所以你需要中間有人翻譯,我認爲這是太多的工作。最簡單的方法是編輯現有應用程序中的代碼。 – Sreekar

回答

1

簡單地在兩個現有應用程序之間插入Kafka並不一定是個好主意,尤其是如果他們不會利用它,比如比例尺。因爲你沒有描述你的用例,所以我不知道。

這就是說,如果它是你想要做的,你可以使用Kafka Connect將現有的應用程序與Kafka集成。你應該能夠建立:

  • 一個源連接器:接收來自應用程序的JSON請求,並把它們插入的記錄到卡夫卡
  • 宿連接器:從卡夫卡提取記錄,並將它們發送到後端

見連接文檔:http://kafka.apache.org/documentation/#connect

相關問題