/etc/localtime是用来描述本机时间,而 /etc/timezone是用来描述本机所属的时区。
kafka报错too many open files,需要修改ulimit限制。
kafka 2.3 增加了incremental cooperative rebalancing,对大规模消费者集群的重平衡进行优化。
kafka 2.3增加group.instance.id配置,支持对client静态化配置id,减少client重启后加入group导致rebalance。
kafka 0.11以后版本,broker增加了 group.initial.rebalance.delay.ms 配置项,空消费组接收到成员加入请求后,coordinator推迟若干时间后再开始rebalance流程。
max.poll.interval.ms 表示单个consumer线程处理一批records的最大timeout。 session.timeout.ms 表示进程级别的超时。