TLDR;有没有办法让kafka-engine导入线程优先于任何其他CH线程,或者我可以为kafka消费者保留CPU?
在我的设置中,当发出一个大查询时,kafkalag会增加太多。我猜,这是因为当CPU负载过高时,导入线程没有接收到足够的CPU时间。我尝试为用户设置最大线程上限,同时也设置了较好的值。似乎什么都不管用,所以欢迎任何建议。
发布于 2021-01-27 21:13:09
升级到20.9.7.11
使用设置kafka_num_consumers=5(10), kafka_thread_per_consumer=1重新创建kafka引擎表
添加到默认配置文件(users.xml) background_schedule_pool_size=30
https://stackoverflow.com/questions/65900470
复制相似问题