网络客户端js上的Kafka

Question

我不知道客户端(js文件(如何订阅主题e显示主题中发布的每条消息。。。

我使用的是laravel，我可以向kafka发布一条消息(例如在控制器中(，但我如何读取js客户端文件中的消息来附加一些你请求的ajax？我怎么知道de producer发布了一条消息？

我用了推进器，它很简单。。。因为他们有一个像这样的客户端的js代码

// Initiate the Pusher JS library
var pusher = new Pusher('API_KEY_HERE', {
encrypted: true
});
// Subscribe to the channel we specified in our Laravel Event
var channel = pusher.subscribe('status-liked');
// Bind a function to a Event (the full Laravel class)
channel.bind('App\Events\StatusLiked', function(data) {
// this is called when the event notification is received...
});

有人能帮我吗？

Answer 1

您必须将JS连接到服务器上的WebSocket，服务器在那里维护一个Kafka消费者；没有前端Kafka客户端。