我正在尝试将移动应用程序数据推入kafka broker。我读过很多文章和博客，知道有rest代理可以把http上的数据推送到kafak代理。我跟着https://docs.confluent.io/current/kafka-rest/docs/quickstart.html# 得到rest代理的味道。练习是可以的，但我想得到一些真实世界的例子。曾跟踪从android/ios应用程序向kafka或hadoop发送数据。我只是想知道mobile=>rest-proxy=>kafka-broker是如何工作的。
如何配置请分享需要采取的步骤。
1条答案
按热度按时间az31mfrm1#
我建议您创建自己的restapi，主要是为了了解它是如何工作的，以及您的应用程序将如何与之通信。在服务器端代码中，您可以嵌入输入验证，这是特定于您的用例的自定义逻辑。对于任何有效的数据，你都可以将其发送给Kafka制作人。
这样，您将能够从较高的层次理解体系结构的所有部分，并在需要时在客户端负载之外定制kafka事件。
如果您对此不满意，则需要按照rest代理的安装说明更具体地说明所遇到的问题，因为我相信，如果您遇到问题，confluent可能会提供一个很好的反馈，以尝试适应和修复文档。
学习如何在android上使用okhttp、volley或其他javahttp库完全是这条管道的另一端，可能还需要几天/几周的时间来学习如何使用它们
另一个选项是使用mqtt/amqp/jms，而不是rest和kafka连接器，但我认为这是假设您已经准备好了基础设施