如何在没有jass登录模块的情况下对IBMMessageHub进行身份验证

vwhgwdsa  于 2021-06-08  发布在  Kafka
关注(0)|答案(1)|浏览(291)

我曾尝试使用liberty for java应用程序在bluemix上设置到kafka消息中心的连接。我以文档和git存储库为例。它创建/使用 jaas.conf 文件很好,说它登录了。但是,当编写一条消息时,它会显示“60000毫秒后更新元数据失败”。为了编写一条消息,我必须向 server.xml 文件:

<jaasLoginModule id="KafkaClient"
            className="org.apache.kafka.common.security.plain.PlainLoginModule"
            controlFlag="REQUIRED" libraryRef="kafkaLoginLib">

    <options serviceName="kafka" username="MYUSERNAME" password="MYPASSWORD" />
</jaasLoginModule>

但是,文档中说(在“如何将kafka客户端从0.9.x迁移到0.10.x”下):
删除消息中心登录jar模块。
改变你的想法 jaas.conf 文件到以下代码: KafkaClient { org.apache.kafka.common.security.plain.PlainLoginModule required serviceName="kafka" username="<your username>" password="<your password>"; }; 将以下行添加到您的消费者和生产者属性: sasl.mechanism=PLAIN 我是不是漏了什么?好像说明书上说我不再需要这个模块了,但是没有它我就无法让它工作。

zc0qhyus

zc0qhyus1#

这些文档是正确的,不过当使用liberty时,您在server.xml而不是jaas.comf文件中定义了。
请使用0.10.x客户端查看我们更新的liberty示例
https://github.com/ibm-messaging/message-hub-samples/tree/master/kafka-java-liberty-sample
该示例不再包括不推荐使用的messagehub login.jar

相关问题