我想在kafka进程启动时运行一个自定义jar。我的自定义jar添加了比kafka使用的基本zookeeper服务发现更详细的服务发现特性。
我怎样才能让Kafka在启动时加载我的jar？
我想听听某些事件，比如连接状态的改变（比如“statechangedtoinit/connecting/reconnecting/disconnected”等等）。有办法订阅这些活动吗？
我正在考虑一个“插件接口”，我可以用它来检索上述功能。我找不到任何相关的东西。把jar加到Kafka身上 /libs/ folder使jar被加载到类路径，但它没有被执行。