【问题标题】:Integrate existing application interface with Kafka [closed]将现有的应用程序接口与 Kafka 集成 [关闭]
【发布时间】:2017-10-18 23:04:38
【问题描述】:

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

该应用程序不受我的控制,因此我无法更改它的通信方式。应用程序向 REST API 后端发送 JSON 请求。

如何在不更改代码的情况下将 Kafka 放在应用程序及其后端之间?

【问题讨论】:

  • JSON 请求是一个 http 请求,因为 Kafka 使用它自己的协议进行通信。所以你需要一个中间人来翻译,我认为这是太多的工作。最简单的方法是在现有应用中编辑代码。

标签: java json rest apache-kafka


【解决方案1】:

在 2 个现有应用程序之间简单地插入 Kafka 不一定是一个好主意,特别是如果他们不会利用它,例如规模。由于您没有描述您的用例,我无法确定。

也就是说,如果您想这样做,您可以使用 Kafka Connect 将现有应用程序与 Kafka 集成。您应该能够构建:

  • 源连接器:接收来自应用的 JSON 请求并将它们作为记录插入到 Kafka 中
  • 一个 Sink 连接器:从 Kafka 中提取记录并将它们发送到后端

请参阅 Connect 文档:http://kafka.apache.org/documentation/#connect

【讨论】:

    猜你喜欢
    • 1970-01-01
    • 2014-03-02
    • 2021-03-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 2012-05-14
    • 1970-01-01
    相关资源
    最近更新 更多