KafkaScheduler用于启动定时任务,根据配置的backgroundThreads的数目初始化线程池
executor =new ScheduledThreadPoolExecutor(threads)
KafkaScheduler的schedule方法传入一个函数,主要用于ReplicaManager和LogManager的调用。
KafkaScheduler用于启动定时任务,根据配置的backgroundThreads的数目初始化线程池
executor =new ScheduledThreadPoolExecutor(threads)
KafkaScheduler的schedule方法传入一个函数,主要用于ReplicaManager和LogManager的调用。
本文标题:KafkaScheduler
本文链接:https://www.haomeiwen.com/subject/ajxadftx.html
网友评论