問題タブ [message-hub]

Kafka Broker の IBM Bluemix 実装を使用しています。

次のプロパティで KafkaProducer を作成しています。

これにより、次の例外が発生しました。

org.apache.kafka.common.KafkaException: org.apache.kafka.clients.producer.internals.DefaultPartitioner は org.apache.kafka.clients.producer.Partitioner のインスタンスではありません

次のブログを読んだ後: http://blog.rocana.com/kafkas-defaultpartitioner-and-byte-arrays新しい API を使用していたにもかかわらず、プロパティ ファイルに次の行を追加しました。

今、私はこの例外を受けています:

org.apache.kafka.common.KafkaException: クラス kafka.producer.ByteArrayPartitioner をインスタンス化できませんでした 引数のない public コンストラクターはありますか?

ByteArrayPartitionerデフォルトのコンストラクターがないようです。ここで何が欠けているのか分かりますか?

ありがとうマドゥ

このチュートリアルに従って、Bluemix のストリーミング分析サービスを使用してメッセージ ハブとやり取りしました: https://developer.ibm.com/bluemix/2015/10/16/streaming-analytics-message-hub-2/?cm_mc_uid =45284031179414585919178&cm_mc_sid_50200000=1464112496

エラーが発生します：

原因: org.apache.kafka.common.KafkaException: javax.security.auth.login.LoginException: LoginModule クラスが見つかりません: com.ibm.messagehub.login.MessageHubLoginModule

ありがとう

Message Hub (Apache Kafka) のログ サイズを 1 GB (retention.bytes) から 50 GB に増やし、Public Bluemix でログ保持を 24 時間から増やす方法はありますか?

上記のコードを使用してメッセージ ハブにメッセージを公開しようとすると、常に次のエラーが発生します。

2016-06-21 18:38:22-[INFO] com.ibm.cloudant.streaming.messageHub.Client.send(476): >>>> document_id julia30 @ my_database 2016-06-21 18:38:22 を送信中-[デバッグ] org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.maybeUpdate(623): メタデータ要求を送信するためにノード -1 への接続を初期化します 2016-06-21 18:38:22-[デバッグ] org.apache.kafka .clients.NetworkClient.initiateConnect(487): kafka01-prod01.messagehub.services.us-south.bluemix.net:9093 でノード -1 への接続を開始しています。2016-06-21 18:38:22-[デバッグ] org.apache.kafka.common.security.authenticator.SaslClientAuthenticator$1.run(105): SaslClient の作成: client=multiuser-adapter@multiuser.messagehub.ibm.com ;service=kafka;serviceHostname=kafka01-prod01.messagehub.services.us-south.bluemix.net;mechs=[GSSAPI] 2016-06-21 18:38:22-[DEBUG] com.

プロデューサーの設定は次のようになります。

```

```

以上の設定で、Message Hub REST API を使ってトピックを作成するのに問題はありません。メッセージを公開しようとすると問題が発生します。

どんな考えでも大歓迎です。

Bluemix MessageHub が保管時のデータ暗号化をサポートしているかどうかを理解する必要があります。保管時のデータ暗号化を直接サポートしていない場合、コンシューマーまたはプロデューサーからこれを実装するためのベスト プラクティスはありますか?

github のメッセージ ハブ Java サンプルに従っています。独自のバージョンの Kafka プロデューサーを作成しましたが、Java メイン アプリケーションを使用して J2Se 環境で正常に動作します。以下のコード スニペット -

カフカ クライアント バージョン - 0.90

このコードを J2EE MDB でラップし、BPM サーバーにデプロイすると。MDB が起動すると、スレッドは send() を待機し続けます:-

RecordMetadata recordMetadata = kafkaProducer.send(producerRecord).get();

しばらくするとタイムアウトします。その他の例外やエラーはスローされません。

私の質問は、BPM 内から kafka クライアント API を使用するには、ssl 構成などの追加の手順を実行する必要があるかということです。

お知らせ下さい。

ありがとう。

Bluemix 上にプロビジョニングされた IBM Message Hub のインスタンスがあります。IBM Message Hub のこのインスタンスに接続してメッセージを受信できるようにする必要があるローカル マシンで実行する Java レシーバーを実装しました。

Bluemix から IBM Message Hub インスタンスに接続できるようにするには、VCAP_SERVICES をどのようにセットアップすればよいですか? [サービス資格情報] タブに移動すると、1 セットの資格情報が構成されています。キー名は MHCredentials です。その JSON 値は次のとおりです。

ローカル マシンで実行されているレシーバーから MessageHub に接続できるように VCAP_SERVICES を設定する方法を教えてください。上記の JSON 文字列を使用して、自分のマシンに VCAP_SERVICES という環境変数を既に作成しています。ただし、レシーバーを実行すると、エラーが発生しました: Not a JSON Array.

Message Hub から Bluemix の Spark インスタンスにメッセージをストリーミングしています。Java クライアントを使用してメッセージ ハブに単純な json メッセージを入れています。

JSON メッセージ -

Spark でストリーミングを開始すると、受信したメッセージの先頭に余分な null があります。

Spark コンテキストがこの null を前に置く理由を教えてください。どうすれば削除できますか?

KafkaSender コード -

ありがとうラージ

現在、開発にはメッセージハブを使用しています。MessageHub の次のインスタンスが構成されています。

ただし、アプリケーションを起動しようとすると、次のエラーが発生します。

これは何が原因ですか？この機能を使用するアプリケーションのモジュールを起動することはできません。

ミヒル