java写一段kafka造数程序

下面是一个使用 Java 编写的 Kafka 生产者示例，用于发送数据到 Kafka 集群：

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) {
        String topicName = "test_topic";
        String message = "Hello, Kafka!";
        String bootstrapServers = "localhost:9092";

        Properties props = new Properties();
        props.put("bootstrap.servers", bootstrapServers);
        props.put("acks", "all");
        props.put("retries", 0);
        props.put("batch.size", 16384);
        props.put("linger.ms", 1);
        props.put("buffer.memory", 33554432);
        props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
        props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");

        KafkaProducer<String, String> producer = new KafkaProducer<>(props);
        ProducerRecord<String, String> record = new ProducerRecord<>(topicName, message);

        producer.send(record);
        producer.close();
    }
}

这个示例通过 KafkaProducer 类创建一个 Kafka 生产者，并使用 ProducerRecord 类创建一个消息。然后，使用 send() 方法将消息发送到指定的主题。最后，关闭生产者。