kafka producer:获取错误producer response with correlation network\u exception

voase2hg  于 2021-06-08  发布在  Kafka
关注(0)|答案(1)|浏览(420)

我们正在2台服务器上以分布式模式运行kafka。我通过javasdk向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:29148[kafka producer network thread | producer-1]warn producer.internals.sender-在主题分区bpa\u binlogq-0上获得相关id为353736的错误生成响应,正在重试(剩余0次尝试)。错误:网络异常

7fhtutme

7fhtutme1#

你得到了一个网络异常,所以这应该告诉你,有什么是错误的网络连接到Kafka经纪你正在生产的目标。由于某种原因,代理关闭或tcp连接关闭。

相关问题