Kafka可以保证消息在一个Partition分区内的顺序性。如果生产者按照顺序发送消息,Kafka将按照这个顺序将消息写入分区,消费者也会按照同样的顺序来读取消息(通过自增偏移量)。
retries
: 消息投递失败重试次数max.in.flight.requests.per.connection
: 生产者在收到kafka响应之前可以投递多少个消息retries > 0
重试次数大于0且max.in.flight.requests.per.connection > 1
会发生:前面一批次消息写入失败,后面一批次的消息写入成功,重试之后,前面一批次的消息写入成功,那么消息的顺序就产生了问题。retries
设置为0 ,不重试,那么消息肯定是有序的,只不过存在消息投递失败丢失的情况。max.in.flight.requests.per.connection
设置为1,在接收到Kafka响应之前,只允许一个批次的消息处于投递中的状态,这当然会严重影响Kafka的吞吐量。retries>0; max.in.flight.requests.per.connection=1