You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@kafka.apache.org by 阮良 <ru...@163.com> on 2021/01/25 06:52:39 UTC

Question for KafkaRequestHandler

Hi Folks, 
   I am confused about the code below ，why the IO thread set the daemon ?   
in my thought , daemon thread is not suitable for some importment work 


def createHandler(id: Int): Unit = synchronized {
runnables += new KafkaRequestHandler(id, brokerId, aggregateIdleMeter, threadPoolSize, requestChannel, apis, time)
  KafkaThread.daemon("kafka-request-handler-" + id, runnables(id)).start()
}