Kafka Producer：通过相关NETWORK_EXCEPTION得到错误产生响应-Java 学习之路

我们在两台服务器上以分布式模式运行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 - 在主题分区BPA_BinLogQ-0上获得错误产生响应，相关ID为353736，重试（剩下0次尝试） . 错误：NETWORK_EXCEPTION

1 回答

1

您正在获取NETWORK_EXCEPTION，因此这应该告诉您与您正在生产环境的Kafka Broker的网络连接出现问题 . 由于某种原因，代理关闭或TCP连接已关闭 .

回复于 2024-05-06T05:44:40+08:00

Kafka Producer：通过相关NETWORK_EXCEPTION得到错误产生响应

1 回答

相关问题