kafka-producer-api

1熱

2答えて

特定のカフカプロデューサーまたはトピックにclient-idを割り当てる方法は？

私は基本的に私は、クォータが正しく私の質問はどのようにすることができますで動作するかどうかをテストするために、特定のクライアントIDとカフカ・プロデューサー-PERF-テストを実行したいクォータがクライアントID に基づいていることを知っています特定のプロデューサー（または）パーティションにclient-idを割り当てますか？

4熱

1答えて

カフカリーダー選挙はいつ行われますか？

カフカハイレベルプロデューサーがリーダーを選ぶ時期と頻度は？各メッセージを送信する前に、または接続の作成時に1回だけ行うのですか？

0熱

1答えて

大きなメッセージを処理するApache Kafkaの.NETプロデューサクライアントを設定中にエラーが発生しました

私は.NET client (producer and consumer) of Apache Kafkaを使用しています。送信できる最大メッセージのサイズを増やそうとしています。私はconfiguration manualと私の問題に関するいくつかの記事を読む： Kafka: Sending a 15MB message https://github.com/confluentinc/kafk

1熱

1答えて

カフカプロデューサのRecordTooLargeExceptionを解決するには？

私はFlinkKafkaProducer08を使用してカフカにレコードを送信しています。しかし、私はエラーメッセージで印刷しているレコードのサイズが0.02 MBと小さすぎるにもかかわらず、次の例外を取得することがあります。 java.lang.RuntimeException: Could not forward element to next operator Caused by: java

3熱

1答えて

kafkaコンシューマフェッチAPIが正しいオフセット値を返しません

3つのブローカと3つのパーティションを持つ実験的なカフカ環境を設定しました。私はプロデューサとコンシューマを持っています。特定のコンシューマのパーティションのオフセットを変更したい。私はkafkaのドキュメントで、kafkaの消費者コミット/フェッチAPIが特定のオフセットをコミットできること、または消費者が読み込んだ最新のオフセットをフェッチできることを読んでいます。私は、特定の消費者からのオフ

1熱

1答えて

私はスクリプトを使用するとカフカにデータを生成できませんが、スクリプトでトピックをリストすることができます

ローカルエリアネットワークに仮想サーバーがあり、ipは192.168.18.230、マシンipは192.168.0.175です。今日、私はカフカのコンソールプロデューサー $ bin/kafka-console-producer.sh --broker-list 192.168.18.230:9092 --topic test で、私の仮想サーバ（192.168.18.230）にいくつかのメ

0熱

1答えて

KafkaProducer onCompletion（）コールバックは常に同じスレッドで実行されますか？

カフカAPI 0.10.1：Link onCompletionコールバックが同じスレッドで順番に呼び出される保証はありますか？ドキュメンテーションは、 "コールバックは一般的にプロデューサのI/Oスレッドで実行されることに注意してください"と言います。だから私はないと思うだろう。たとえば、整数カウンタを保持することによって発生した例外の数を追跡したい場合は、AtomicIntegerを使用する必

2熱

2答えて

エラー：パッケージorg.apache.kafka.clients.producerはありません

私はkafkaを初めて使っています。私は javac -cp "C:\kafka\kafka_2.11-0.10.2.0\libs\kafka-clients-0.10.2.0.jar" *.java このコマンドを実行すると、私はエラーメッセージ error: package org.apache.kafka.clients.producer does not exist

0熱

1答えて

kafkaのプロデューサーから消費者にオブジェクトを消費する方法は？

以下は、プロデューサとコンシューマのクラスです。いつデータを生成することができ、次のコードでそれを消費することができません。一度私をここで助けることができますか？私はコーディングに間違っていましたか？私の目的は、消費者からCustomMessageオブジェクトを読んで、そのデータをDBに格納することです。私のcmdプロンプトでは、zookeeperのインスタンス1、kafkaの1、プロデューサの

0熱

1答えて

org.apache.kafka.common.errors.UnknownTopicOrPartitionException：このサーバーは、このトピックパーティションをホストしていない

私は今、私は次のようexceptionを取得しています、最初はそれが2日間私のために働いた、カフカにjson objectを送っていますjavaを使用して Exception in thread "main" java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.UnknownTopicOrPartition