赞
踩
max.in.flight.requests.per.connection指定了生产者在接收到服务器相应之前可以发送多个消息。
kafka在1.x版本之前保证单分区有序,条件如下
max.in.flight.requests.per.connection=1
2) kafka在1.x及以后版本保证数据单区间分区有序,条件如下
未开启幂等性
max.in.flight.requests.per.connection需要设置为1
开启幂等性
max.in.flight.requests.per.connection需要设置小于等于5
原因说明:因为kafka1.x以后,启动幂等后,kafka会缓存producer发来最近的5个request源数据,故无论如何,都可以保证最近5个request数据是有序的
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。