producer

0熱

1答えて

socket.errorのためにKafka Producerを実行できません：[Errno 48]アドレスはすでに使用中です

私はローカルドッカーマシンを持っており、私はPythonで書かれたKafkaプロデューサーを実行しようとしています。しかし、それはsocket.errorを与えます：[Errno 48]アドレスはすでに使用中であり、停止しています。助けてくれてありがとう！エラーメッセージ：ドッキングウィンドウ・マシン上ドッカーマシン画像コンテナコマンドプロデューサーを実行します $ python pro

0熱

1答えて

kafka-avro-console-producerのインストール方法は？

私は 'kafka-console-producer'を使用するとJASSファイルを自動的に取り出し、正常に実行されます（リモートトピックに生成される可能性があります）。私が使用している場合は「カフカ - アブロ・コンソール・プロデューサー」まったく同じ構成でなく、追加されたスキーマプロパティを持つ - それはJASS構成文句： 'Could not find a 'KafkaClient' e

0熱

2答えて

kafkaのプロデューサのパーティション数をpartitionForメソッドを使用して0.8.0にする

kafkaバージョン0.8.0のプロデューサでpartitionsForメソッドをサポートしていますか？私は、このメソッドを使用して、カフカのトピックを与えられたパーティションの数を取得します。この方法をkafka 0.8.0で使用できない場合、この特定のバージョンのkafkaでプロデューサのパーティション数を取得する最も簡単な方法は何ですか？

0熱

1答えて

iTunesのプロデューサのjava.net.MalformedUrlException

iTunesプロデューサにePubを公開しようとしています。 ePubファイルはepubcheckツールで検証にパスします。 EPUBを提出しながら、私は、次のエラーが発生します： Error: Internal error: java.net.MalformedURLException: unknown protocol: bundle schema/20/rng/container.rng"

0熱

1答えて

ActiveMQ、複数のセッションと複数の接続

現在のプロジェクトでActiveMQを使用したいのですが、複数の接続をいつ利用するのか混乱することはほとんどありません。 1つの接続で複数のプロデューサを作成できるため、複数の接続を持つ必要があります。私はそれをオンラインで見つけようとしましたが、それを深く理解するのに役立つ有用なリソースが見つかりませんでした。誰かがactivemqを使って実際に経験したことを共有でき、それぞれのプロデューサ

1熱

1答えて

Windows上でlibrdkafkaのKAFKAのプロデューサAPIとC++コードを使用する方法

プロデューサとしてクライアントを作成しようとしています。私は新しいWin32コンソールプロジェクトを作成するための例を続けました。プログラムの最後にgetline（）関数を追加しない限り、私のAPIが動作しないことがわかりました。 getline（）を削除しても、produce（..）メソッドは依然として成功の結果を返します。しかし、私はkafka-console-consumerのコマンド

1熱

1答えて

パイプコンシューマー/プロデューサー：コンシューマー/プロデューサーと言えば、フォーク後の父/息子

まず、悪い英語が使用されている場合はごめんなさい。私の注意書きでは、子プロセスは通常プロデューサですが、その理由を理解できません。 fork（）コールの後で、消費者とプロデューサは誰ですか？問題は、子プロセスがプロデューサである場合、彼は父が行う前に終了することになります。つまり、子プロセスはゾンビプロセスになります。それは問題ではありません

0熱

2答えて

コンフルエントKafka Pythonライブラリ一括生成のためのプロデューサを設定する

私はmsgではなく一括インポートの1つのバッチで500のmsgを送信するようにKafkaプロデューサを設定する必要があります。私はhttps://github.com/dpkp/kafka-python/issues/479をチェックしproducer.send_messages(topic, *message) を試みたが、それはエラーで失敗しますので、私はより多くを掘る、私が持っていることが判

0熱

1答えて

KAFKA REMOTE AWS consumer.poll

こんにちは、私はKAFKAを学び、私の遠隔ポーラー/消費者に問題を抱えています。私はKAFKAをプライベートおよびパブリックIPを使用してAWS EC2インスタンスにセットアップしました。私のserver.propertiesは次のようになります。リスナー= PLAINTEXT：//172.31.31.58：9092 #AWSプライベートIP advertised.listeners = PL

0熱

2答えて

カフカプロデューサー例外のNoClassDefFoundError

私はカフカのプロデューサーといくつかの問題を抱えているが、私はそれをマイMavenの依存関係を解決する方法を知らない： <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka_2.10</artifactId> <version>0.10.1.1</version> </dependen