java发送数据到kafka

您好！要在Java中发送数据到Kafka，您需要使用Kafka提供的Java客户端库。以下是一个简单的示例代码，演示如何发送数据到Kafka：

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

import java.util.Properties;

public class KafkaProducerExample {
    public static void main(String[] args) {
        String topicName = "your_topic_name";
        String bootstrapServers = "your_bootstrap_servers";

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

        try {
            // 发送一条消息到Kafka
            String message = "Hello, Kafka!";
            ProducerRecord<String, String> record = new ProducerRecord<>(topicName, message);
            producer.send(record, new Callback() {
                @Override
                public void onCompletion(RecordMetadata metadata, Exception exception) {
                    if (exception != null) {
                        System.out.println("消息发送失败：" + exception.getMessage());
                    } else {
                        System.out.println("消息发送成功，偏移量：" + metadata.offset());
                    }
                }
            });

            // 关闭Kafka生产者
            producer.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

请确保替换`your_topic_name`和`your_bootstrap_servers`为您的实际值，然后运行此代码即可将消息发送到Kafka中的指定主题。