Replies: 1 comment 1 reply
-
The main reason for |
Beta Was this translation helpful? Give feedback.
1 reply
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.
-
Hello,
We are facing some significant CPU usage increase on kafka broker when increasing the number of consumers (different groups but same topic for testing purpose) connected to the broker even if no data is published to the topic. We have tested this using kafkacat/kcat utility (based on librdkafka) and we have found that increasing the value of fetch.wait.max.ms in our kafka customers significantly reduce the pressure on the kafka broker.
I am now trying to understand why default values for fetch.wait.max.ms and and fetch.min.bytes are respectively 500 ms and 1 byte for a kafka consumer and what would be the impact of increasing fetch.wait.max.ms. Since the default value of fetch.min.bytes is 1 it seems to me that increasing fetch.wait.max.ms will not have any impact on consumer latency and throughput since data will be delivered "immediately" (when poll is done) to the consumer. Is there any reason why fetch.wait.max.ms is not higher by default (increasing fetch.min.bytes does not reduce cpu usage of kafka broker in idle mode)? What would be the impact in customer if I increase etch.wait.max.ms but keep fetch.min.bytes to 1?
Thanks
Beta Was this translation helpful? Give feedback.
All reactions