返回到文章

采纳

编辑于

kafka 存放消息 报错Connection reset by peer

kafka

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