那说明你的 kafka_init 没有被调用?
那说明你的ide 没有找到 lib,你可以添加一下你的 erlang lib ,你编译过了后在_build目录下的。
观察到你都用了 5.5.1的企业版本了,为什么不直接用 5.9.0 的版本,这个版本不区分企业,开源版本,kafaka 的功能都不需要自己开发。全是开箱即用的。完全没必要写插件啊。