Clojurescript lang中的Kafka消费者

abithluo 于 2023-05-16 发布在 Apache

关注(0)|答案(2)|浏览(151)

有没有一种方法可以在我正在尝试创建的clojurescript应用程序中创建Kafka消费者。我的Kafka集群位于AWS MSK，它被配置为使用SASL_SSL/IAM授权。我的客户端应用程序是基于clojurescript构建的。我试图搜索工作的第三方库，但找不到任何clojurescript。有没有人知道在cljs中创建消费者的其他方法。
我尝试了一些clojure库，如clj-kafka，kafkaesque，devoplt/kafka等，但都不起作用。

apache-kafka

来源：https://stackoverflow.com/questions/76226157/kafka-consumers-in-clojurescript-lang

2条答案

按热度按时间

vc9ivgsu1#

您不能使用Clojure客户端，因为它们可能会使用Java客户端实现或直接通过Java IO系统进行接口。这些在Clojurescript中不存在，因此是不兼容的。
你想寻找JS客户端，而不是使用它们。我怀疑从客户端直接与Kafka交谈是不是一个好主意，但我从未使用过它，所以我不知道这是否是一个选择。
最常见的设置可能是人们从他们的服务器与Kafka交谈，然后为前端提供自己的API。我确信你可以使用JS API客户端在ClojureScript中编写这样一个服务器，但我不能指出任何具体的东西。

赞(0）回复(0）举报 2023-05-16

kq0g1dla2#

Kafka不是前端技术。Kafka的大多数GUI都假设直接连接，并且不使用 AJAX 。这就是你想要的，不管客户端库如何，使用像Confluent的Kafka REST代理这样的HTTP代理
然后，您所需要的只是一个HTTP客户端，而不是特定于Kafka的客户端

赞(0）回复(0）举报 2023-05-16