kafka 存放消息 报错Connection reset by peer

请叫我马里奥 发表于: 2017-05-04   最后更新时间: 2017-05-04 14:26:10   4,205 游览

您好!
我想问一下,我使用producer.send发送消息后,没有执行producer.close(),因为我send消息的频率很高,我不想每次send消息都先new KafkaProducer<>(props),send完后close(),我怕这样会影响效率.
这样我再我本地一次一次的执行还没有问题,但是放在服务器上就有问题,我的服务器是两台机器的一个小集群。
请问我需要什么配置才能解决这个问题呢

发表于 2017-05-04
添加评论

producer.close()是最后不用的时候才会调用的,不是每次调用。

你的答案

查看kafka相关的其他问题或提一个您自己的问题