我在1.0.0-cp1版本的Kafka集群的工作台上工作.
在我的工作室的一部分,他们专注于订购保证和没有数据丢失的最大吞吐量(只有一个分区的主题),需要我将max.in.flight.requests.per.connection属性设置为1？
我已经读过这篇文章
了解我只需要将max.in.flight设置为1,如果我使用该retries属性启用我的制作人的重试功能.
要问我的问题的另一种方法:只有一个分区+重试= 0(生产者道具),足以保证在卡夫卡的顺序？
我需要知道,因为增加max.in.flight会大大增加吞吐量.