KafkaScheduler

2018-05-20  本文已影响0人  是我_7b3f

KafkaScheduler用于启动定时任务,根据配置的backgroundThreads的数目初始化线程池

executor =new ScheduledThreadPoolExecutor(threads)

KafkaScheduler的schedule方法传入一个函数,主要用于ReplicaManager和LogManager的调用。

上一篇下一篇

猜你喜欢

热点阅读