slink使用kafka报错

eKuiper
1

使用docker部署 lfedge/ekuiper:1.11-alpine
安装kafka插件后，配置规则
显示报错信息：
io error: kafka sink fails to send out the data: read tcp 172.18.0.11:44608->192.168.1.218:9092: read: connection reset by peer
规则配置如下：
"kafka": { "resourceId": "218", "batchSize": 1, "brokers": "192.168.1.218:9092", "insecureSkipVerify": true, "maxAttempts": 1, "saslAuthType": "none", "topic": "uiam-audit", "headers": "{\"key\":\"value\"}", "omitIfEmpty": false, "sendSingle": true, "format": "json", "dataTemplate": "{\"hello\":\"world\"}", "bufferLength": 1024, "enableCache": false, "runAsync": false }

2

使用1.12.0-alpha.4-alpine版本，kafka插件功能正常，不存在上述问题

3

好的，感谢反馈。Kafka sink/source 在当前正在开发的 1.12 版本里一直在持续更新。