用java给我写一个kafka生产者代码，读取txt文件，以json格式发送到kafka集群

好的，以下是Java代码示例：

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

public class KafkaProducerExample {

public static void main(String[] args) throws Exception {

// 设置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);

// 读取txt文件并将其转换为JSON格式
BufferedReader br = new BufferedReader(new FileReader("example.txt"));
String line;
while ((line = br.readLine()) != null) {
// 将每一行文本转换为JSON格式
String json = "{\"message\":\"" + line + "\"}";

// 发送JSON格式的消息到Kafka集群
ProducerRecord<String, String> record = new ProducerRecord<>("test-topic", json);
producer.send(record);
}
br.close();

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