我正在学习Zookeeper,但遇到了一些困惑。我查阅了各种论坛和问题,但都没有解决我的疑惑。最终我来到SO寻求以下问题的答案:
据我理解,Zookeeper工作在主从架构中。那么Kafka如何适应这种架构?每个Kafka集群中的代理是否作为客户端连接到Zookeeper服务器集合,或者生产和消费消息的用户应用程序作为Zookeeper集合的客户端?
对于一个特定的topic/partition,一个Kafka代理会被占用,如果它接收到太多的消息(无法处理),是否有可能使用一致性哈希来分配负载,Zookeeper架构支持这种操作吗?
更新: Zookeeper是否类似于DynamoDB中用于成员和故障检测的Gossip协议的变体?