kafka-数据乱序
kafka1.x版本之前
需要设置:max.in.fight.requests.per.connection=1
让生产者缓存发送数据为1(不需要考虑幂等性)
kafka1.x版本之后
-
在未开启幂等性时,需要和1.x之前一样让生产者缓存发送数据为1
-
在开启幂等性后,可以让生产者缓存5个以内的数据
因为启动幂等性后,kafka会缓存生产者发来的最近5个请求的数据,所以可以保证最近5个数据是有序的
kafka1.x版本之前
需要设置:max.in.fight.requests.per.connection=1
让生产者缓存发送数据为1(不需要考虑幂等性)
kafka1.x版本之后
在未开启幂等性时,需要和1.x之前一样让生产者缓存发送数据为1
在开启幂等性后,可以让生产者缓存5个以内的数据
因为启动幂等性后,kafka会缓存生产者发来的最近5个请求的数据,所以可以保证最近5个数据是有序的