KafkaScheduler
2018-05-20 本文已影响0人
是我_7b3f
KafkaScheduler用于启动定时任务,根据配置的backgroundThreads的数目初始化线程池
executor =new ScheduledThreadPoolExecutor(threads)
KafkaScheduler的schedule方法传入一个函数,主要用于ReplicaManager和LogManager的调用。
KafkaScheduler用于启动定时任务,根据配置的backgroundThreads的数目初始化线程池
executor =new ScheduledThreadPoolExecutor(threads)
KafkaScheduler的schedule方法传入一个函数,主要用于ReplicaManager和LogManager的调用。