kafka-数据乱序

kafka-数据乱序

起男 435 2022-03-08

kafka-数据乱序

kafka1.x版本之前

需要设置:max.in.fight.requests.per.connection=1让生产者缓存发送数据为1(不需要考虑幂等性)

kafka1.x版本之后

  • 在未开启幂等性时,需要和1.x之前一样让生产者缓存发送数据为1

  • 在开启幂等性后,可以让生产者缓存5个以内的数据

    因为启动幂等性后,kafka会缓存生产者发来的最近5个请求的数据,所以可以保证最近5个数据是有序的