正常启动emqx,并将GitHub - nananatsu/emqx_plugin_kafka 通过make rel 打包成插件,成功在emqx的dashboard上启动该插件,我能再编写一个插件在emqx dashboard上启动成功后,使用到emqx_plugin_kafka插里的方法吗?
比如我希望能再另一个插件中使用emqx_plugin_kafka插件中的发送kafka消息的方法。
可以的
你好能告知一下怎么调用吗,比如
-module(emqx_plugin_kafka).
-include_lib("emqx/include/logger.hrl").
-export([
start_kafka/1, send_msg_to_kafka/6, start_producer/5
]).
我想使用其中的send_msg_to_kafka方法 该怎么调用呢?
打包完成后的插件包名是emqx_plugin_kafka-0.1.tar.gz
您能给我示例一下代码中如何引用吗?
就和你正常跨模块调用一样:emqx_plugin_kafka:send_msg_to_kafka(...)