Kafka生产者 - 多个主题

下面是一个使用Kafka生产者发送消息到多个主题的示例代码：

import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.ProducerRecord;
import java.util.Properties;

public class KafkaProducerExample {

    public static void main(String[] args) {
        // 配置Kafka生产者
        Properties props = new Properties();
        props.put("bootstrap.servers", "localhost:9092");
        props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
        props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");

        // 创建Kafka生产者
        KafkaProducer<String, String> producer = new KafkaProducer<>(props);

        // 发送消息到多个主题
        String[] topics = {"topic1", "topic2", "topic3"};
        String message = "Hello, Kafka!";
        for (String topic : topics) {
            ProducerRecord<String, String> record = new ProducerRecord<>(topic, message);
            producer.send(record);
        }

        // 关闭Kafka生产者
        producer.close();
    }
}

上述代码中，我们首先配置了Kafka生产者的参数，包括Kafka集群地址、序列化器等。然后创建了一个KafkaProducer对象。接下来，我们定义了要发送的消息内容和多个主题。在循环中，我们为每个主题创建一个ProducerRecord对象，并使用producer.send()方法发送消息。最后，我们关闭了Kafka生产者。

请注意，上述代码中的主题名称是示例值，您需要根据实际情况更改为您自己的主题名称。另外，您还需要确保Kafka集群的地址和端口与代码中的配置匹配。