消息来到broker分区,经由ProducerState的数据进行对比,
- 如果新消息的序列号是连续的,Broker会接受并存储该消息,然后更新最新序列号。
- 如果新消息的序列号不连续,Broker会认为这是重复消息或乱序消息,根据配置,它可能会丢弃或拒绝该消息。
- 无论消息被接受还是丢弃,Broker都会返回一个ack给生产者。
不连续时可能拒绝多个消息,那么这些消息都会返回生产者重新发送,直到按顺序下一个消息到来,才存储并更新。
消息来到broker分区,经由ProducerState的数据进行对比,
不连续时可能拒绝多个消息,那么这些消息都会返回生产者重新发送,直到按顺序下一个消息到来,才存储并更新。