使用kafka-configs动态更新Kafka JAAS配置不生效问题求助

我的Kafka Broker的server.properties包含以下配置：

listener.name.internal.plain.sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required \
  username="broker" password="admin_password" \
user_admin="test123";

listener.name.external_sasl.plain.sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required \
  username="broker" password="admin_password" \
user_admin="test123";

使用用户名user_admin和密码test123可以正常生产消息。但尝试更新user_admin的密码时，发现修改必须重启Broker才生效。我用以下命令应用修改：

kafka-configs --bootstrap-server localhost:9092 --broker 1 --alter --add-config-file /etc/kafka/users.conf

/etc/kafka/users.conf的内容如下：

listener.name.internal.plain.sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required \
  username="broker" password="admin_password" \
user_admin="test1234";

listener.name.external_sasl.plain.sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required \
  username="broker" password="admin_password" \
user_admin="test1234";

此时用密码test1234生产消息会提示用户名/密码错误，只有重启Broker后才能正常使用。我确认ZooKeeper中已经存在更新后的配置，而且理解kafka-configs应该支持无需重启的动态更新，请问问题出在哪？

• 问题核心：Kafka自带的PlainLoginModule不支持动态更新JAAS配置。它会在Broker启动时一次性把JAAS配置里的用户密码加载到内存，后续哪怕通过kafka-configs修改了ZooKeeper中的配置，这个模块也不会主动重新读取配置。JAAS配置本身属于JVM启动时的初始化项，默认不会在运行时动态刷新。
• 实现动态用户密码更新的可行方案：
  1. 切换到支持动态认证的SASL机制，比如SASL/OAUTHBEARER，或者集成LDAP这类外部认证服务，它们可以在运行时从外部数据源读取用户信息，无需重启Broker。
  2. 若必须使用Plain认证，可开发自定义LoginModule，让它定期从数据库、配置中心等外部存储读取最新的用户密码信息，实现动态更新。
  3. 不要再通过kafka-configs修改listener.*.sasl.jaas.config这类配置，它们不属于Kafka官方支持的动态可更新配置列表，即便修改了ZooKeeper中的值，Broker也不会生效。

内容的提问来源于stack exchange，提问作者CJW