Kafka生产者API：bootstrap.servers属性值

在Kafka生产者API中，bootstrap.servers属性用于指定Kafka集群的地址。以下是一个包含代码示例的解决方法：

import org.apache.kafka.clients.producer.*;

import java.util.Properties;

public class KafkaProducerExample {

    public static void main(String[] args) {
        // 设置Kafka集群的地址
        String bootstrapServers = "localhost:9092";

        // 创建Kafka生产者的配置
        Properties props = new Properties();
        props.put("bootstrap.servers", bootstrapServers);
        props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
        props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");

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

        // 创建要发送的消息
        String topic = "my-topic";
        String key = "key1";
        String value = "Hello, Kafka!";

        // 创建Kafka消息记录
        ProducerRecord<String, String> record = new ProducerRecord<>(topic, key, value);

        // 发送消息
        producer.send(record, new Callback() {
            @Override
            public void onCompletion(RecordMetadata metadata, Exception exception) {
                if (exception != null) {
                    System.err.println("发送消息失败：" + exception.getMessage());
                } else {
                    System.out.println("消息发送成功，offset：" + metadata.offset());
                }
            }
        });

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

在上面的示例中，我们创建了一个KafkaProducer实例，并设置了bootstrap.servers属性为"localhost:9092"，这是Kafka集群的地址。然后，我们创建了一个ProducerRecord对象来指定要发送的消息的主题、键和值。最后，我们使用producer.send()方法发送消息，并通过回调函数处理发送结果。最后，我们关闭了Kafka生产者。