kafka-python

1熱

1答えて

私は、SASL_SSL（認証（JAAS）と承認）を有効にしたKafka10クラスタを使用しています。 Javaクライアントを使用してSASLを介して下位のプロップと接続することができます。 ssl.keystore.location="client_keystore.jks" ssl.keystore.password="password" ssl.truststore.location="c

0熱

1答えて

kafka python - Bluemix MessageHub - ConnectionError：socket disconnected

私はkafka pythonクライアントを使ってメッセージをMessage Hubにプッシュしていますが、メッセージハブへのメッセージの送信を中断してしまったことに気付きました。私はその後、私のログファイルに次のように気づい： ConnectionError: socket disconnected 私はretries=5を追加するために自分のコードを更新： from kafka impor

2熱

2答えて

KafkaからJSONメッセージを消すことができないKafka-Pythonのデシリアライザを使用

私は非常に単純なJSONオブジェクトをKafkaを通して送信し、Pythonとkafka-pythonを使用して反対側から読もうとしています。 2017-04-07 10:28:52,030.30.9998989105:kafka.future:8228:ERROR:10620:Error processing callback Traceback (most recent call last)

0熱

1答えて

カフカプロデューサーが私のコードを停止

私はカフカプロデューサーからデータを送信する関数を呼び出していますが、送信した後は返さないレスポンスを返しています。コードは返ってきてしまいます。誰でも何が起きているのでしょうか？次のように私のコードは def postEvent(eventData): print("The eventData is...",eventData) timestamp = datetime.n

0熱

1答えて

Kafka Python Client - 可能な接続/タイムアウトエラーを処理する方法は？

私はKafkaのキューに接続し、キューにメッセージを送信するPythonアプリケーションを書いています。私は私が直面するかもしれない例外のいずれかの種類をキャッチできるように、このコードでは、標準のtry-catch式を追加したい def send_msg(self, topic, msg): self.producer = KafkaProducer(bootstrap_servers

0熱

1答えて

OverflowErrorの取得：kafka-pythonプロデューサ - コンシューマの使用中にタイムアウト値が大きすぎる

まあ、私はプロデューサからコンシューマに単純なデータtansferを持たせるためにPythonでKafka-pythonパッケージ（1.3.2）を使用しようとしています。プロデューサー： from kafka import KafkaProducer producer = KafkaProducer(bootstrap_servers='localhost:9092') # produce

0熱

2答えて

ローカルマシンからEC2マシンで実行中のKafkaを接続する

私はKafkaを初めて使用していて、フォーラムで別の投稿を検索しましたが、解決策が見つかりませんでした。私はkafkaをEC2インスタンスにインストールし、私のubuntuローカルマシンから同じものを接続しようとしています。私の目的は、ローカルマシン上でpython kafkaクライアント（プロデューサとコンシューマの両方）を実行し、EC2 kafkaインスタンス経由でデータを送受信することです。

1熱

2答えて

Bluemixメッセージハブ - SASL認証を初期化できませんでしたが、まだ動作しているようです。

BluemixメッセージハブをPythonで使用しようとすると、エラーと失敗が続きます。理由は何ですか？エラーは、「SASL認証の初期化に失敗しました：（メカニズムPLAINで必要）ブローカーでサポートされていないSASLハンドシェイク」されている私の生産者と消費者を実行したときにはしかし、彼らが動作するようです。メッセージが生成され、メッセージが消費されます。私の出力には、エラーメッセージ

0熱

1答えて

カフカプロデューサーはレプリカの存在下でクォータレートでデータを供給できますか？

私はクライアントIDが "p1"で、クォータが50MBpsのクライアントに属するカフカプロデューサーを持っています。 "bin/kafka-producer-perf-test.sh"を使用して私のプロデューサのパフォーマンスをテストしました。レプリカなしでパーティションに書き込むとき、50 MBpsに近いスループットを得ることができました。 3つのレプリカを持つパーティションで同じ実験を試みまし

2熱

1答えて

`kafka-python`でバイナリメッセージをポーリングすることができません

私はバイナリデータ（生のパケットキャプチャデータ）を受信しているKafkaトピックを持っています。 Kafka CLIツールを使用して実際に着陸データであることを確認できます。私は毎秒複数のメッセージを受け取ります。 kafka-console-consumer.sh --zookeeper svr:2181 --topic test しかし、kafka-pythonを使用すると、メッセー