我在Linux上使用的是librdkafka-0.11.5 for C。我的C/C++应用程序只是将Kafka数据发送到web服务器,该服务器使用ElasticSearch驱动Kafka消费者。看起来在生产者端,Kafka为每个Unix进程增加了8(8)个内部线程。这给我们带来了一个问题,因为我们对每个Linux机器的线程数量有一个硬性限制。
有没有人知道为什么增加了8个线程?会不会是因为我的Linux机器有4个CPU,并且线程池是预先创建的,每个CPU有两个线程(只是推测)?我使用一个主题和六