如何解决如何生成作为 POST 请求到达 Confluent Kafka 主题的事件
我正在使用一个将事件数据作为 POST 请求推送的应用程序。我无法控制应用程序如何发送请求，也无法控制这些请求的外观。我需要将这些事件生成到 Kafka 主题中。
起初我认为 Confluent REST 代理 API 可以工作，但由于我无法控制 POST 请求的外观，因此我无法使用此 API。
然后我想也许有一个 Confluent 连接器，这会很好，因为它们可以扩展并且很好地与 Kafka 集群集成。但是只有一个 HTTP 接收器，只有一个源。
我使用 GCP，我的研究将我带到了 Cloud Functions 或 Cloud Run。所以现在我的想法是编写一个小型 Python 程序（监听请求，从请求中提取数据，并生成主题），制作一个 Docker 镜像，然后将它部署到 Cloud Run 上，这有望扩展它。
我不是很有经验，所以我的问题是处理这个问题的最佳方法是什么，也许我缺少一个明显的解决方案。
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。