Kafka：动态更新jaas配置
我已经使用sasl为Kafka设置了jaas配置。贾斯。配置属性。我想更新此配置并动态添加用户。
根据这个文档-http://kafka.apache.org/11/documentation.html#dynamicbrokerconfigs，我们可以通过使用bin/kafka-configs.sh来做到这一点。
我已尝试更新sasl。贾斯。使用以下命令配置：
bin/kafka-configs.sh--bootstrap-serverlocalhost:9092实体类型的经纪人实体名称59-改变--add-configsasl.jaas.config="KafkaServer{\norg.apache.kafka.common.security.plain.PlainLoginMoules必需\n username=\"myuser\"\n密码=\"myPassword2\"；\n}；\nClient{\norg.apache.zookeeper.server.auth.DigestLoginMoules必需\n用户名=\"myuser2\"\n密码=\"myPassword2\"；\n}；"
但它给了我以下错误：
要求失败：无效的实体配置：要添加的所有配置必须采用“key=val”格式。
如果我查看上面的列，它会显示sasl的值的格式。贾斯。config属性是（=）*。这意味着什么？
sasl.jaas.config的值应该如何传递来动态更新jaas配置？
共有1个答案
虽然可以动态更新sasl。贾斯。config要添加更多用户，默认的普通登录模块不打算在生产中使用。
相反，您应该定义回调处理程序来处理用户的身份验证。这在KafkaSasl普通文档中有描述。
另一个需要更多工作（但更具灵活性）的选项是创建自己的登录模块。Kafka能否提供自定义LoginModule以支持LDAP中描述了该过程？
关于您得到的错误消息，这似乎是kafka-config.sh工具的问题。它不期望配置值包含=< /code>。您应该能够使用AdminClient API更新该配置。
我在JIRA中找不到现有问题，因此创建了一个新问题：https://issues.apache.org/jira/browse/KAFKA-8010
-
V1.1.1新增 <?php $data=array("URL_HTML_SUFFIX"=>".html"); $result=sp_set_dynamic_config($data); ?>
-
我有一个spring boot kafka客户端应用程序，其中有两个消费者在kafka中收听不同的主题和不同的消费者群。 为了实现，我需要下面有两个JAAS会议(使用不同的keytab文件) dc-jaas-A.conf文件 dc-jaas-B.conf 由于下面的connect tFactory在System.setProperty中设置dc-jaas-A.conf和dc-jaas-B.conf
-
我试图连接到Kafka使用汇流。Kafka包。但是，我需要使用jaas作为身份验证方法。我找不到使用融合的方法。Kafka为。NET. 编辑： 我收到以下数据连接： 我试图建立这样的联系： 你们知道我怎么设置收到的Jaas吗？
-
一旦提交，配置服务器就在刷新endpoint发布更新后的值:http://localhost:8888/camelspringbootsample/dev 我还在http://localhost:8181/Actuator/env提供了Camel应用程序endpoint 在这里，属性的值不会在刷新时更新。但是，如果我重新启动Camel应用程序，则会反映出该值。 你能帮我做这个吗？提前谢了。
-
问题内容： 我基本上有一个具有多个选项卡的MainActivity。每个选项卡都是一个ShowListFragment，它扩展了Fragment。现在，每个选项卡都包含我从数据库中获取的数据。我有一个MOVE按钮，可将数据从每个片段的一个选项卡移动到另一个选项卡： 片段不会直接更新，而是在选项卡之间滑动了几下（恰好3次）。单击按钮后如何强制片段立即更新？我不想通过ViewPager中的onPage
-
我希望能够动态更新我的Swing GUI的LookAnd感到属性。在这种情况下，我有一个简单的Swing/Awt游戏，运行的最初是Nimbus。在启动后的不同时间点，我想更改（让我们说）一个细节：我的应用程序的背景颜色。 我可以通过这样做来改变背景颜色： 这“有效”，因为应用程序的背景颜色会正确更改并且程序不会崩溃。但是在命令行上我收到错误： 显然，有些东西是空的，但我不知道它是什么，也不知道如何