単一のカフカプロデューサーが複数のトピックにメッセージを生成する方法は？

Question

私はちょうどKafkaを探索しています、現在、メッセージを生成するために1つのproducerと1つのトピックを使用しています。これは1つだけConsumerによって消費されます。非常に簡単です。

私はKafkaページを読んでいましたが、new Producer API is thread-safeと共有すると、パフォーマンスが向上します。

1つのProducerを使用して複数のトピックにメッセージを公開することはできますか？

Answer 1

自分で試したことはありませんでしたが、できると思います。プロデューサーやレコードを送信するためのコードは（ここではhttps://kafka.apache.org/090/javadoc/index.html?org/apache/kafka/clients/producer/KafkaProducer.htmlから）ですので：

だから、

Producer<String, String> producer = new KafkaProducer<>(props); 
for(int i = 0; i < 100; i++) 
    producer.send(new ProducerRecord<String, String>("my-topic", Integer.toString(i), Integer.toString(i))); 

あなただけProducerRecordでさまざまなトピックを書いた場合、それは可能なはずよりも、私は、推測します。

また、ここではhttp://kafka.apache.org/081/documentation.html#producerapiは、send(List<KeyedMessage<K,V>> messages)という方法を使用して複数のトピックに書き込むことができると明示しています。