我们正在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次尝试)。错误:网络异常
1条答案
按热度按时间7fhtutme1#
你得到了一个网络异常,所以这应该告诉你,有什么是错误的网络连接到Kafka经纪你正在生产的目标。由于某种原因,代理关闭或tcp连接关闭。