java连接kafka服务器java代码

以下是Java连接Kafka服务器的示例代码：

import org.apache.kafka.clients.producer.Producer;
import org.apache.kafka.clients.producer.ProducerRecord;
import org.apache.kafka.clients.producer.KafkaProducer;
import java.util.Properties;

public class KafkaProducerExample {
    public static void main(String[] args) {
        String topicName = "test-topic";
        String key = "key1";
        String value = "value1";

        Properties props = new Properties();
        props.put("bootstrap.servers", "localhost:9092");
        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");

        Producer<String, String> producer = new KafkaProducer<>(props);

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

        producer.close();
    }
}

此示例使用Kafka生产者API将消息发送到名为“test-topic”的主题中。在此示例中，我们使用了本地Kafka服务器的默认端口9092。您可以根据需要更改主题名称，键和值。您还可以更改Kafka服务器的地址和端口，以便将消息发送到远程服务器