zookeeper.session.timeout.ms 适用于消费者还是经纪人?
does zookeeper.session.timeout.ms apply to consumer or broker?
zookeeper.session.timeout.ms: ZooKeeper session timeout. If the consumer fails to heartbeat to ZooKeeper for this period of time it is considered dead and a rebalance will occur.
据我了解,此配置是代理设置。从 netstat 命令,它还显示只有 kafka 连接到 zookeeper。 kafka 消费者根本没有连接到 zookeeper。谁能解释 consumer 在此设置中的含义?
在旧的 Kafka 版本中(直到 0.8,后来它是可选的),消费者使用 ZooKeeper 来存储偏移量。现在,它为此使用内部 Kafka 主题,消费者不再与 ZooKeeper 通信。
zookeeper.session.timeout.ms: ZooKeeper session timeout. If the consumer fails to heartbeat to ZooKeeper for this period of time it is considered dead and a rebalance will occur.
据我了解,此配置是代理设置。从 netstat 命令,它还显示只有 kafka 连接到 zookeeper。 kafka 消费者根本没有连接到 zookeeper。谁能解释 consumer 在此设置中的含义?
在旧的 Kafka 版本中(直到 0.8,后来它是可选的),消费者使用 ZooKeeper 来存储偏移量。现在,它为此使用内部 Kafka 主题,消费者不再与 ZooKeeper 通信。