Kafka发送消息
场景描述
在ZK模式下,如果所有broker节点之间均无法通讯,broker与ZK的通讯正常,那么生产者能否正常发送消息(ack=all)?
解释
生产者能否正常发送消息,取决于producer是如何配置的。
- 如果你配置了acks=all并且min.insync.replicas=2的话,那么由于ISR收缩到1,无法满足,于是生产者发送消息失败。
- 如果你配置了acks=all并且min.insync.replicas=1的话,那么生产者发送成功。
总结
能否正常发送消息,取决于你的配置。