java - KafkaProducer不发送记录

Question

我对 Kafka 完全陌生，在使用 KafkaProducer 时遇到了一些问题。生产者的 send 方法正好阻塞 1 分钟，然后应用程序继续执行，不会出现异常。这显然是超时，但没有抛出异常。

我在日志中也看不到任何内容。

服务器已正确设置。如果我使用 bin/kafka-console-consumer 和 Producer 应用程序，我可以正确发送和接收消息。而且代码在某种程度上也可以工作。如果我想写入尚不存在的主题，我可以在/tmp/kafka-logs 文件夹中看到新条目，也可以在 KafkaServer 的控制台输出中看到。这是我使用的代码:

    Properties props = ResourceUtils.loadProperties("kafka.properties");
    Producer<String, String> producer = new KafkaProducer<>(props);

    for (String line : lines)
    {
        producer.send(new ProducerRecord<>("topic", Id, line));
        producer.flush();
    }
    producer.close();

kafka.properties 文件中的属性:

bootstrap.servers=localhost:9092
key.serializer=org.apache.kafka.common.serialization.StringSerializer
value.serializer=org.apache.kafka.common.serialization.StringSerializer
acks=all
retries=0
batch.size=16384
linger.ms=1
buffer.memory=33554432

因此， Producer.send 会阻塞 1 分钟，然后继续。最后，Kafka 中没有存储任何内容，但创建了新主题。感谢您的帮助!

Answer 1

尝试将 bootstrap.servers 设置为 127.0.0.1:9092