kafka 像生产者写数据

Apache Kafka 是一个分布式流处理平台，主要用于构建实时数据管道和数据湖，特别适合于大规模、高吞吐量和低延迟的数据传输场景。作为生产者，你可以使用 Kafka 提供的客户端库向主题（Topic）中写入数据，这个过程通常包含以下几个步骤：

1. **创建生产者实例**：首先，你需要创建一个 `KafkaProducer` 或者更现代的 `KafkaProducer<关键值, 消息体>` 对象，这取决于你的消息是否携带键值对。

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092"); // 替换为实际的 broker 地址
KafkaProducer<String, String> producer = new KafkaProducer<>(props);

2. **设置消息格式**：确定要发送的消息类型，这里是一个简单的字符串，但可以根据需求定制。

3. **准备消息**：定义要发送的主题名（Topic Name）和消息内容。

String topicName = "my-topic";
String message = "This is a sample message";

4. **发送消息**：调用 `send()` 方法将消息发送到指定主题。

ProducerRecord<String, String> record = new ProducerRecord<>(topicName, message);
producer.send(record);

5. **提交事务（可选）**：在某些情况下，生产者可能会选择开启事务，确保消息的批量发送成功。如果开启了事务，需要调用 `producer.commitSync()` 来确认发送。

6. **关闭连接**：当生产任务完成后，记得关闭 `KafkaProducer` 对象以释放资源。

producer.close();