KafkaScheduler用于启动定时任务,根据配置的backgroundThreads的数目初始化线程池
executor =new ScheduledThreadPoolExecutor(threads)
KafkaScheduler的schedule方法传入一个函数,主要用于ReplicaManager和LogManager的调用。
KafkaScheduler用于启动定时任务,根据配置的backgroundThreads的数目初始化线程池
executor =new ScheduledThreadPoolExecutor(threads)
KafkaScheduler的schedule方法传入一个函数,主要用于ReplicaManager和LogManager的调用。