kafka-producer-api

0熱

1答えて

私はカフカとストリーミングを使い慣れていますので、私に同行してください。私は動物園とカフカの両方を正常にインストールして起動しました。シンプルなトピックを作成し、そのトピックに送信されているものをコンソールでリッスンして表示するコンソールコンシューマを開始しました。プロデューサは現在、エンドポイント呼び出しの結果として情報を送信します。私はNMEA形式のデータをTCPポートに送信するデバイス

4熱

1答えて

Kafkaのプロデューサとコンシューマの設定（Java API）を取り戻すには？

ユースケースは以下のとおりです。 Javaコード内の多くのオブジェクトインスタンスに対して、プロデューサまたはコンシューマ参照を渡しています。そのうちのいくつかでは、カフカ設定のチェックをしたいと思います。私は、どのような効果的な設定がKafka Producer/Consumer（デフォルトを含む）に格納されているかを知りたいと考えています。私は、Javaのドキュメントに明示的anthin

0熱

1答えて

カフカブローカーに直接生産しているWebフロントエンドは実行可能なアイデアですか？

私はちょうどカフカを学び始めました。ソーシャルメディアWebアプリケーションを構築しようとしています。私は、バックエンド（バックエンドからデータベースやその他のサービスへの通信）にKafkaを使用する方法についてかなり明確です。しかし、フロントエンドとバックエンドとの通信方法はわかりません。私はアーキテクチャを次のように考えていた：フロントエンド - >カフカ - >バックエンド。フロントエン

0熱

1答えて

カフカのブローカーリストと1つのブローカーの間に接続を作成していますか？

私はカフカクラスターを運営しています。サンプルコード： Properties props = new Properties(); props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092,localhost:9093,localhost:9094"); KafkaProducer<Str

1熱

2答えて

リーダーが利用できませんコンソールでのKafka ssl + acl設定のプロデューサ

sfl + aclsでkafka 0.11.0.1を使用しようとしています。私の設定は以下の通りです。 server.properties： broker.id=0 listeners=PLAINTEXT://127.0.0.1:9092,SSL://127.0.0.1:9093 advertised.listeners=SSL://127.0.0.1:9093 num.network.th

0熱

2答えて

Kafka Producerを作成し、send（）、flush（）、close（）メソッドを呼び出す正しい順序は何ですか？

私はカフカのプロデューサーを作り、さまざまな方法を呼び出すという異なるモデルを持っていますが、フローを破らずパフォーマンスに影響を与えないようにプログラムする正しいアプローチが何であるかはわかりません。親切に助けてください。モデル1： for(int i=1; i < 100; i++){ Producer<String, String> producer = new KafkaPro

0熱

1答えて

KafkaConsumerとKafkaProducerのアイドル時間設定

私たちのアプリケーションは長時間実行されており、停止/強制終了するまで実行する必要があります。そのための設定は、longのプロデューサとコンシューマの両方にconnections.max.idle.msを設定することです。無限に設定したり、閉じたりしないように設定する方法はありますか？ connections.max.idle.msを10分に設定すると、プロデューサは何も生成されないため、20分間

0熱

1答えて

Python - Kafka：consumer failing

私はシンプルなプロデューサー - コンシューマーのセットアップをしています：1人のプロデューサー（スレッドとして）と2人のコンシューマー（2つのプロセスとして）。プロデューサーのrunメソッド： def run(self): producer = KafkaProducer(bootstrap_servers=self.bootstrap_servers, a

0熱

1答えて

Confluent.Kafka.Producer <TKey、TValue> .ProduceAsyncはスレッドセーフですか？

// // Summary: // Asynchronously send a single message to the broker. Refer to Confluent.Kafka.Producer`2.ProduceAsync(System.String,`0,`1,System.Int32,System.Boolean) // for more inf

0熱

1答えて

org.springframework.kafka.listener.ListenerExecutionFailedException：リスナーメソッドがjava.lang.NullPointerExceptionをスローしました

私のコンシューマークラスInventoryEventReceiverのリスナーメソッドで以下のエラーが発生しました。 NullPointerExceptionが表示される理由がわかりません。私はちょうど2つのInventoryEventオブジェクトを投稿しています。迅速なヘルプがあれば幸いです。私はカフカRESTプロキシを介して2つのレコードの下にPOSTしていたリスナー方法 public c