Clojurescript lang 中的 Kafka 消费者

问题描述 投票:0回答:2

有没有办法在我正在尝试创建的 clojurescript 应用程序中创建 kafka 消费者。我的 kafka 集群位于 AWS MSK,它配置为使用 SASL_SSL/IAM 身份验证。我的客户端应用程序是基于 clojurescript 构建的。我尝试搜索可用的第三方库,但找不到 clojurescript 的任何内容。有谁知道在 cljs 中创建消费者的其他方法吗?

我尝试了一些 clojure 库,如 clj-kafka、kafkaesque、devoplt/kafka 等,但没有任何效果。

apache-kafka kafka-consumer-api clojurescript aws-msk clojurescript-javascript-interop
2个回答
0
投票

您无法使用 Clojure 客户端,因为它们可能会直接通过 Java IO 系统使用 Java 客户端实现或接口。这些在 Clojurescript 中不存在,因此不兼容。

您想要寻找 JS 客户端并使用它们。我怀疑从客户端直接与 Kafka 对话是个好主意,但我从未使用过它,所以我不知道这是否是一个选择。

最常见的设置可能是人们从服务器与 Kafka 对话,然后为前端提供自己的 API。我确信您可以使用 JS API 客户端在 ClojureScript 中编写这样的服务器,但我无法向您指出任何具体内容。


0
投票

Kafka 不是前端、技术。大多数 Kafka 的 GUI 都假设直接连接,并且不使用 AJAX...这就是您想要的,无论客户端库如何,都使用 HTTP 代理,例如 Confluence 的 Kafka REST 代理

然后,您需要的只是一个 HTTP 客户端,而不是 Kafka 特定的客户端

© www.soinside.com 2019 - 2024. All rights reserved.