萌新的拉布拉多

好的，谢谢大佬

你删除和加入权限的代码没有任何问题，这个主要是springboot的消费者加载问题。

1. java是静态语言，springboot第一次就初始化进行开始消费了。
2. 当你删除权限时，这个消费者组线程就结束了。

没有逻辑重新初始化这个消费者了，所以你需要重新启动这个微服务，进行重新初始化。

我个人觉得这个行为是非常正确的，权限一旦确认就不会反复修改，所以这个场景本身就非常非常少。

你想，什么情况下消费者组会脱离，oom或微服务宕机的时候才会脱离，本身就与进程共存亡的。所以也没有人去专门写个逻辑，去维护你这个场景。一直去尝试加入消费者试错权限才是最大的灾难。

java是静态语言，默认连接kafka也是需要提前指定帐密的。

但是，如果你非要这么实现，你就需要通过rest调用传入帐密，然后在创建连接kafka客户端的实现。
这样比较麻烦，而且毫无意义。