私は、異なるトピックが設定されたプロデューサを持っています。すべてのプロデューサが同じファイルをリッスンしているため、1秒に複数のイベントが発生するため、すべてのイベントが互いに異なります。下記のサンプルをご覧ください。 1つのメッセージとして各イベントを考慮カフカの異なるトピックに異なるメッセージを送る方法
A event1 B event2 C event3 A event4 C event5 B event6 D event7 E event8 F event9 E event10
。イベントファイルを聞いているプロデューサのリストから、対応するトピックに異なるメッセージを送る方法。
ありがとうございました。 よろしくお願いします。
あなたはKafkaのドキュメントを見ましたか？ ：A、Bなどは、単に以下のコードでAなどで "私のトピック" を置き換える、所望の目的地のトピックの名前であると仮定すると
Producer<String, String> producer = new KafkaProducer<>(props);
producer.send(new ProducerRecord<String, String>("my-topic", "my-key", "my-value");
入力を聞く1人のカフカプロデューサーがいないのはなぜですかファイルに書き込まれたそれぞれの新しいイベントの内容に基づいて異なるトピックに公開しますか？
これは良いアプローチですが、1000種類のイベントがあります。 EPS（イベント/秒）帯域幅は非常に高く、毎秒1ギガバイトです。 –
ありがとうMichael.here A、Bなどはさまざまなデバイスからのメッセージです。だから私はそれぞれのために作成したトピックにA、Bなどのメッセージを送る必要がある。私が直面する問題は、すべてのデバイスが同じファイルにログを送信することです。私は、デバイスでログを区別するためのキーフィールドを持っています。前述のように、A、Bなどは微分です。 –
申し訳ありませんが、私にはあなたの問題が何であるかは分かりません。おそらく上記の質問を更新/改善する必要があります。 –