KafkaProducer未发送记录

Question

我对Kafka是完全陌生的，我在使用Kafka制作人时遇到了一些麻烦。生成器的send方法恰好阻塞1min，然后应用程序无一例外地继续。这显然是一些超时，但没有抛出异常。

我在原木上也看不出什么真正的东西。

    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