【发布时间】:2019-06-12 09:47:39
【问题描述】:
我有一个关于如何将 kafka 生产者与前端 Web 应用程序集成的问题。获取每分钟或每秒的数据。 Web 应用程序可以在每次创建 JSON 对象时将其传递给正在运行的生产者吗?还是每次拿到JSON对象都需要启动kafka客户端?
【问题讨论】:
标签: django apache-kafka kafka-producer-api confluent-platform kafka-python
我有一个关于如何将 kafka 生产者与前端 Web 应用程序集成的问题。获取每分钟或每秒的数据。 Web 应用程序可以在每次创建 JSON 对象时将其传递给正在运行的生产者吗?还是每次拿到JSON对象都需要启动kafka客户端?
【问题讨论】:
标签: django apache-kafka kafka-producer-api confluent-platform kafka-python
您可能希望为每个会话打开一个新的生产者,可能不会为每个请求打开和关闭。这将在后端完成,而不是前端。
但是由 Kafka 客户端组成的 Web 服务器在 HTTP 层下与常规控制台应用程序没有什么不同;您接受传入的请求,对其进行反序列化,然后选择性地解析,然后再次序列化以获取 Kafka 输出,然后选择性地将某些内容呈现给用户。
如果您真的要问“是否可以使用 HTTP 请求的 Kafka”,不管语言和平台如何,那么可以肯定的是,the Confluent REST Proxy 的操作方式类似,只是用 Java 编写的
就 webapps 跟踪而言,我建议查看 Divolte Collector
【讨论】: