我见过像rabbitmq或apachepulsar这样的代理提供websocketapi来直接将浏览器连接到代理。阿飞,我还没见过Apache·Kafka也一样。您必须自己实现一个中间websocket服务器。为什么拥有ApacheKafka开发的confluent没有像rabbitmq或pulsar那样提供现成的websocket api?
oymdgrw71#
Kafka和websocket之间已经有了一个开源连接。https://github.com/b/kafka-websocket如果你有从浏览器连接到Kafka的要求,我建议你考虑浏览这个http://github.com/confluentinc/kafka-rest-node
ha5z0ras2#
confluent不拥有ApacheKafka开发。ApacheKafka是Apache软件基金会(ASF)拥有的一个项目。关于如何将websockets与apache kafka结合使用,有几个示例:https://www.confluent.io/blog/data-stream-processing-with-kafka-streams-bitrock-and-confluent/https://dev.to/victorgil/kafka-websockets-angular-event-driven-microservices-all-the-way-to-the-frontend-12aahttps://medium.com/swlh/angular-spring-boot-kafka-how-to-stream-realtime-data-the-reactive-way-510a0f1e5881你的问题似乎有点修辞性,但如果你真的想把websockets看作apachekafka的一部分,那么第一步就是提出一个kafka改进建议(kip),供社区讨论。这里有一个dev邮件列表,您可以从中获得关于贡献代码过程的进一步指导。
2条答案
按热度按时间oymdgrw71#
Kafka和websocket之间已经有了一个开源连接。https://github.com/b/kafka-websocket
如果你有从浏览器连接到Kafka的要求,我建议你考虑浏览这个http://github.com/confluentinc/kafka-rest-node
ha5z0ras2#
confluent不拥有ApacheKafka开发。ApacheKafka是Apache软件基金会(ASF)拥有的一个项目。
关于如何将websockets与apache kafka结合使用,有几个示例:
https://www.confluent.io/blog/data-stream-processing-with-kafka-streams-bitrock-and-confluent/
https://dev.to/victorgil/kafka-websockets-angular-event-driven-microservices-all-the-way-to-the-frontend-12aa
https://medium.com/swlh/angular-spring-boot-kafka-how-to-stream-realtime-data-the-reactive-way-510a0f1e5881
你的问题似乎有点修辞性,但如果你真的想把websockets看作apachekafka的一部分,那么第一步就是提出一个kafka改进建议(kip),供社区讨论。这里有一个dev邮件列表,您可以从中获得关于贡献代码过程的进一步指导。