emqx-4.4.16,我用wolff写kafka插件,遇到写法问题,希望官方人员能给点建议

wolff官方给的例子中,看起来每发一次消息,都创建了一次kafka生产者,这样担心影响性能。

我这边的期望是插件启动的时候,把想要的kafka生产者都初始化好了,后续钩子消息到的时候,能直接复用一开始创建好的生产者。

有大佬能给个复用这个生产者的写法例子么?

你在插件启动的时候,调用你拿到的例子中的创建生产者的代码,然后在钩子被触发的时候只发消息就好了。

Shawn大佬,我对erlang不是太熟悉,erlang里面怎么在钩子方法里面调用init的producer变量,可以简单说说么?

不要企图修改它的代码。按常规,起另外一个程序、订阅 topic,然后自己做producer。修改代码这种高级特性,自己做还不如买企业版

只是弄下插件,没有改源码,我已经弄好了