1、Kafka如何保证消息的顺序性
消息在被追加到 Partition(分区)的时候都会分配⼀个特定的偏移量(offset)。Kafka 通过偏移量(offset)来保证消息在分区内的顺序性。
1. 1 个 Topic 只对应⼀个 Partition。 2. (推荐)发送消息的时候指定 key/Partition。
2、如何保证Kafka消息不丢失
生产者发送消息,消息丢失。用失败重试的方式,重新发送,这里一般建议重试次数 >=3 次
消费者消费消息导致消息丢失