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
Uh oh!
There was an error while loading. Please reload this page.
-
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