0

Liberty for Java アプリを使用して、Bluemix で kafka-message-hub への接続をセットアップしようとしました。ドキュメントと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 に移行する方法」の下):

  1. Message Hub ログイン Jar モジュールを削除します。
  2. jaas.confファイルを次のコードに変更します。

KafkaClient { org.apache.kafka.common.security.plain.PlainLoginModule required serviceName="kafka" username="<your username>" password="<your password>"; };

  1. 次の行をコンシューマ プロパティとプロデューサー プロパティに追加します。
    sasl.mechanism=PLAIN

ここで何か不足していますか？このモジュールはもう必要ないと指示されているようですが、それなしでは機能しません。

4

1 に答える 1