美文网首页
KafkaScheduler

KafkaScheduler

作者: 是我_7b3f | 来源:发表于2018-05-20 13:00 被阅读0次

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

    executor =new ScheduledThreadPoolExecutor(threads)

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

    相关文章

      网友评论

          本文标题:KafkaScheduler

          本文链接:https://www.haomeiwen.com/subject/ajxadftx.html