KafkaScheduler用于啟動(dòng)定時(shí)任務(wù)嚣艇,根據(jù)配置的backgroundThreads的數(shù)目初始化線程池
executor =new ScheduledThreadPoolExecutor(threads)
KafkaScheduler的schedule方法傳入一個(gè)函數(shù)跪腹,主要用于ReplicaManager和LogManager的調(diào)用萝衩。
KafkaScheduler用于啟動(dòng)定時(shí)任務(wù)嚣艇,根據(jù)配置的backgroundThreads的數(shù)目初始化線程池
executor =new ScheduledThreadPoolExecutor(threads)
KafkaScheduler的schedule方法傳入一個(gè)函數(shù)跪腹,主要用于ReplicaManager和LogManager的調(diào)用萝衩。