作者回复: 目前没有太严重的bug
作者回复: 每个Broker可以是不同的配置。
作者回复: 你要访问ZooKeeper才能看到ZooKeep下的路径结构。如果你使用的是Kafka自带的zookeeper,可以运行bin/zookeeper-shell.sh zkhost:zkport
作者回复: 这些是INFO级别的日志,Zk上某些节点不存在,不一定就是问题,有其他的ERROR日志吗?
作者回复: 大概率是PRODUCE和FETCH请求。不过你最好结合kafka.network:type=RequestMetrics,name=RequestQueueTimeMs,request={Produce|FetchConsumer|FetchFollower}确认下是否需要调整num.network.threads
作者回复: 可以看看broker端的请求队列的JMX指标
作者回复: 把配置保存在ZooKeeper中,然后动态监听这个变更,一旦监听到立即处理
作者回复: 因为是异步的网络请求。一个Broker上可能有很多follower副本,增加线程可以均匀分散这些follower副本来去任务
作者回复: 可以监控请求队列的大小
作者回复: 不会失效,即使重启
作者回复: 统一的机制。反正消费不到数据的话就发生位移越界的情况