我们在 2 个服务器上以分布式模式运行 kafka。
我正在通过 Java sdk 向 Kafka 发送消息到具有复制因子 2 和 1 分区的队列。
我们以异步模式运行。
我在 Kafka 日志中没有发现任何异常。
任何人都可以帮助找出可能的原因吗?
Properties props = new Properties();
props.put("bootstrap.servers", serverAdress);
props.put("acks", "all");
props.put("retries", "1");
props.put("linger.ms",0);
props.put("buffer.memory",10240000);
props.put("max.request.size", 1024000);
props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
Producer<String, Object> producer = new org.apache.kafka.clients.producer.KafkaProducer<>(props);
异常跟踪:
-2017-08-15T02:36:29,148 [kafka-producer-network-thread | producer-1] WARN producer.internals.Sender - Got error produce response with correlation id 353736 on topic-partition BPA_BinLogQ-0, retrying (0 attempts left). Error: NETWORK_EXCEPTION
最佳答案
您收到了 NETWORK_EXCEPTION,因此这应该告诉您与您正在生产的 Kafka Broker 的网络连接出现问题。由于某种原因,代理关闭或 TCP 连接关闭。
关于apache-kafka - 卡夫卡生产者 : Got error produce response with correlation NETWORK_EXCEPTION,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/45737913/