Kafka消息的生产
如果acks=1,只要集群的首领节点收到消息,生产者就会收到一个来自服务器的成功响应。如果消息成功写入Kafka,就返回一个RecordMetaData对象,它包含了主题和分区信息,以及记录在分区里的偏移量。如果键不为空,并且使用了默认的分区器,那么Kafka会对键进行散列,然后根据散列值把消息映射到特定的分区上。我们知道为了实现高可用,Kafka的分区是建立副本的,指定这个参数也是为了高可用,防止消息丢失。acks参数指定了必须要有多少个分区副本收到消息,生产者才会认为消息写入是成功的。...