我有一个9个分区的Kafka主题,即使使用9个使用者,并且将流传输间隔设置为1秒,我仍然看不到机器的资源投入很大,CPU甚至低于10%(对于8核心,16GB AMI)。
我应该尝试修改其他属性吗?提前致谢。
我发现了问题的根源,流式轮询超时和刷新间隔。
一旦我将以下内容添加到users.xml并重新启动,则接收率显着提高
<stream_poll_timeout_ms>5000</stream_poll_timeout_ms>
<stream_flush_interval_ms>1500</stream_flush_interval_ms>
<max_streams_to_max_threads_ratio>4</max_streams_to_max_threads_ratio>