单个Kafka生产者可以为多个主题生成消息吗？如何生成？

Question

我只是在探索Kafka，目前我正在使用One生产者

我在阅读Kafka页面，新的生产者API是线程安全的，共享单个实例将提高性能。

这是否意味着我可以使用单个生产者向多个主题发布消息？




Answer 1

如果我没理解错的话，您更倾向于使用同一个生产者实例来发送关于多个主题的相同/多个消息。

不确定 Java，但在这里你可以使用Kafka .NET 客户端依赖生成器在 C#（.NET） 中执行此操作

   using (var producer = new ProducerBuilder<string, string>(config).Build())
        using (var producer2 = new DependentProducerBuilder<Null, int>(producer.Handle).Build())
        {
            producer.ProduceAsync("first-topic", new Message<string, string> { Key = "my-key-value", Value = "my-value" });

            producer2.ProduceAsync("second-topic", new Message<Null, int> { Value = 42 });

            producer2.ProduceAsync("first-topic", new Message<Null, int> { Value = 107 });

            producer.Flush(TimeSpan.FromSeconds(10));
        }

Answer 2

我自己从来没有试过，但我想你可以。因为生产商和发送记录的代码是（从这里开始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)));

所以，我想，如果你只是在ProducerRecords中编写不同的主题，那应该是可能的。

此外，这里http://kafka.apache.org/081/documentation.html#producerapi它明确表示您可以使用方法发送（List