about liimiting the number of in-flight requests(eos) #3650
chenhongluo
started this conversation in
General
Replies: 0 comments
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
-
inflight = rd_atomic32_get(&rktp->rktp_msgs_inflight); rdkafka_broker.c(line 3822)
max_requests = RD_MIN(max_requests, RD_KAFKA_IDEMP_MAX_INFLIGHT - inflight); rdkafka_broker.c(line 3867)
why inflight is the number of messages in flight, not request's number
Beta Was this translation helpful? Give feedback.
All reactions