2017-10-18 60 views
-1

我想将现有的应用程序与Kafka集成。将现有的应用程序接口与Kafka集成

该应用程序不受我控制,所以我无法改变它的通信方式。应用程序将JSON请求发送到REST API后端。

如何在不改变代码的情况下在应用程序及其后端之间添加Kafka?

+1

JSON请求是其中作为卡夫卡使用它自己的协议进行通信的HTTP请求。所以你需要中间有人翻译,我认为这是太多的工作。最简单的方法是编辑现有应用程序中的代码。 – Sreekar

回答

1

简单地在两个现有应用程序之间插入Kafka并不一定是个好主意,尤其是如果他们不会利用它,比如比例尺。因为你没有描述你的用例,所以我不知道。

这就是说,如果它是你想要做的,你可以使用Kafka Connect将现有的应用程序与Kafka集成。你应该能够建立:

  • 一个源连接器:接收来自应用程序的JSON请求,并把它们插入的记录到卡夫卡
  • 宿连接器:从卡夫卡提取记录,并将它们发送到后端

见连接文档:http://kafka.apache.org/documentation/#connect

相关问题