Kafka发送消息

Posted by BY 大雁小鱼 on February 2, 2023

Kafka发送消息

场景描述

在ZK模式下,如果所有broker节点之间均无法通讯,broker与ZK的通讯正常,那么生产者能否正常发送消息(ack=all)?

解释

生产者能否正常发送消息,取决于producer是如何配置的。

  • 如果你配置了acks=all并且min.insync.replicas=2的话,那么由于ISR收缩到1,无法满足,于是生产者发送消息失败。
  • 如果你配置了acks=all并且min.insync.replicas=1的话,那么生产者发送成功。

总结

能否正常发送消息,取决于你的配置。