查看consumer group列表有新、旧两种命令,分别查看新版(信息保存在broker中)consumer列表和老版(信息保存在zookeeper中)consumer列表,因而需要区分指定bootstrap–server和zookeeper参数:...
作者:fredalxin地址:https://fredal.xin/talking-msa-a-msa-request
在zookeeper shell中使用get命令查看指定路径节点的data、stat信息:
zookeeper是一个经典的分布式数据一致性解决方案,致力于为分布式应用提供一 个高性能、高可用,且具有严格顺序访问控制能力的分布式协调存储服务。...
源码分析(1)ZooKeeper源码环境搭建
在分布式的应用中,为了防止单点故障,保障高可用,通常会采用主从结构,当主节点挂掉后,从节点可以代替主节点提供服务。
在开始分析 KafkaConsumer 的具体实现之前,我们先来介绍一下 KafkaConsumer 涉及到的一些基础理论。在第一课时介绍 Consumer Group 时提到,对于同一个 Consumer Group 来说,同一个 Topic 的不同 partition 会分配给不同...
根据自己的习惯创建一个路径用来存放kafka程序我选择的是/usr/tools/然后执行解压命令
如果使用默认数据文件路径/tmp/zookeeper也可以不用新建目录,配置文件也可以不用改
本文通过实操Kafka的API来理解topic、partition等相关概念,我将通过搭建一个Kafka集群来实现它。