如何在lua(openresty)中使用kafka?

我正在使用lua(openresty)中的库与kafka交互:github。 Readme.md描述了kafka的SSL支持。 要连接,我使用以下代码

local kafka = producer:new(broker_list,{[“producer.type”] =“async”,[“ssl”] = true)。

我如何初始化truststore_locationkeystore_locationkeystore_passwordkey_password? 我在仓库和stackoverflow中没有找到示例

点赞
用户2032913
用户2032913

sasl 认证目前还不支持。请参考 https://github.com/doujiang24/lua-resty-kafka/pull/102

2021-05-28 10:06:17