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