2023-07-26 20:45:40,846 WARN (pool-15-thread-6|26763) [KafkaUtil$ProxyAPI.sendProxyRequest():181] failed to send proxy request to TNetworkAddress(hostname:10.8.228.137, port:8060) err [too busy to get kafka info, please check the kafka broker status, or set internal_service_async_thread_num bigger]
2023-07-26 20:45:40,846 WARN (pool-15-thread-6|26763) [KafkaUtil$ProxyAPI.sendProxyRequest():192] failed to send proxy request to TNetworkAddress(hostname:10.8.228.137, port:8060) err failed to send proxy request to TNetworkAddress(hostname:10.8.228.137, port:8060) err [too busy to get kafka info, please check the kafka broker status, or set internal_service_async_thread_num bigger]
2023-07-26 20:45:40,846 WARN (pool-15-thread-6|26763) [RoutineLoadTaskScheduler.scheduleOneTask():191] check task ready to execute failed
com.starrocks.common.LoadException: failed to send proxy request to TNetworkAddress(hostname:10.8.228.137, port:8060) err failed to send proxy request to TNetworkAddress(hostname:10.8.228.137, port:8060) err [too busy to get kafka info, please check the kafka broker status, or set internal_service_async_thread_num bigger]
at com.starrocks.common.util.KafkaUtil$ProxyAPI.sendProxyRequest(KafkaUtil.java:193) ~[starrocks-fe.jar:?]
at com.starrocks.common.util.KafkaUtil$ProxyAPI.getOffsets(KafkaUtil.java:134) ~[starrocks-fe.jar:?]
at com.starrocks.common.util.KafkaUtil$ProxyAPI.getLatestOffsets(KafkaUtil.java:114) ~[starrocks-fe.jar:?]
at com.starrocks.common.util.KafkaUtil.getLatestOffsets(KafkaUtil.java:66) ~[starrocks-fe.jar:?]
at com.starrocks.load.routineload.KafkaTaskInfo.readyToExecute(KafkaTaskInfo.java:86) ~[starrocks-fe.jar:?]
at com.starrocks.load.routineload.RoutineLoadTaskScheduler.scheduleOneTask(RoutineLoadTaskScheduler.java:173) ~[starrocks-fe.jar:?]
at com.starrocks.load.routineload.RoutineLoadTaskScheduler.lambda$submitToSchedule$1(RoutineLoadTaskScheduler.java:152) ~[starrocks-fe.jar:?]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_181]
at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_181]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_181]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_181]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_181]
调整 be.conf
internal_service_async_thread_num = 20