我有一个问题，我们如何将Kafka生产者与前端网络应用程序。获取每分钟或每秒钟的数据。web应用程序能否在每次创建json对象时将其传递给正在运行的生产者？还是每次我们得到一个json对象时都需要启动kafka客户机？
apeeds0o1#
您可能希望为每个会话打开一个新的生产者，而不是为每个请求打开和关闭。这将在后端完成，而不是前端。但是，由kafka客户机组成的web服务器在http层下与常规控制台应用程序没有区别；接受传入的请求，反序列化它，然后可选地进行解析，然后再次序列化以获得Kafka输出，然后可选地将某些内容呈现回用户。如果您真的在问，“kafka是否可以使用http请求”，而不考虑语言和平台，那么可以肯定的是，合流rest代理的操作是类似的，只使用java编写就webapps跟踪而言，我建议您调查一下divolte收集器
1条答案
按热度按时间apeeds0o1#
您可能希望为每个会话打开一个新的生产者，而不是为每个请求打开和关闭。这将在后端完成，而不是前端。
但是，由kafka客户机组成的web服务器在http层下与常规控制台应用程序没有区别；接受传入的请求，反序列化它，然后可选地进行解析，然后再次序列化以获得Kafka输出，然后可选地将某些内容呈现回用户。
如果您真的在问，“kafka是否可以使用http请求”，而不考虑语言和平台，那么可以肯定的是，合流rest代理的操作是类似的，只使用java编写
就webapps跟踪而言，我建议您调查一下divolte收集器