大数据全系列 教程
1869个小节阅读:467.9k
目录
408考研
JAVA全系列 教程
面向对象的程序设计语言
Python全系列 教程
Python3.x版本,未来主流的版本
人工智能 教程
顺势而为,AI创新未来
大厂算法 教程
算法,程序员自我提升必经之路
C++ 教程
一门通用计算机编程语言
微服务 教程
目前业界流行的框架组合
web前端全系列 教程
通向WEB技术世界的钥匙
大数据全系列 教程
站在云端操控万千数据
AIGC全能工具班
A A
White Night
添加一个主题topicN,它有3个分区,且每个分区共3个副本(包含Leader在内)。
xxxxxxxxxx
kafka-topics.sh --bootstrap-server node3:9092 --create --partitions 3 --replication-factor 3 --topic topicN
xxxxxxxxxx
[root@node4 ~]# zkCli.sh -server node4:2181
[zk: node4:2181(CONNECTED) 0] ls /kafka
[admin, brokers, cluster, config, consumers, controller, controller_epoch, feature, isr_change_notification, latest_producer_id_block, log_dir_event_notification]
[zk: node4:2181(CONNECTED) 4] ls /kafka/brokers
[ids, seqid, topics]
# 记录broker有哪些服务器
[zk: node4:2181(CONNECTED) 5] ls /kafka/brokers/ids
[0, 1, 2]
# 记录所有的主题
[zk: node4:2181(CONNECTED) 6] ls /kafka/brokers/topics
[__consumer_offsets, __transaction_state, topicN,topicA]
# 查看topicA主题下的子节点
[zk: node4:2181(CONNECTED) 11] ls /kafka/brokers/topics/topicN
[partitions]
# 查看topicA主题下partitions节点的子节点
[zk: node4:2181(CONNECTED) 12] ls /kafka/brokers/topics/topicN/partitions
[0, 1, 2]
[zk: node4:2181(CONNECTED) 13] ls /kafka/brokers/topics/topicN/partitions/0
[state]
[zk: node4:2181(CONNECTED) 14] ls /kafka/brokers/topics/topicN/partitions/0/state
[]
# 查看topicA/partitions/0分区的相关信息
[zk: node4:2181(CONNECTED) 15] get -s /kafka/brokers/topics/topicN/partitions/0/state
{"controller_epoch":2,"leader":0,"version":1,"leader_epoch":0,"isr":[0,2,1]}
cZxid = 0x730000006a
ctime = Sat Apr 02 11:25:10 CST xxxx
mZxid = 0x7600000083
mtime = Wed Apr 06 09:19:35 CST xxxx
pZxid = 0x730000006a
cversion = 0
dataVersion = 3
aclVersion = 0
ephemeralOwner = 0x0
dataLength = 74
numChildren = 0
实时效果反馈
1. 关于Zookeeper节点树保存Kafka信息的描述,错误的是:
A /kafka/brokers/ids
该节点的子节点分别对应一个broker。
B /kafka/brokers/topics
该节点下有__consumer_offsets
和__transaction_state
以及自定义创建的主题,如topicN。
C 主题topicN有几个分区,在/kafka/brokers/topics/topicN/partitions
节点下就会有几个子节点。
D 主题topicN的partitions0分区的相关信息在节点/kafka/brokers/topics/topicN/partitions/0
中保存,比如该分区的Leader是谁,isr列表等。
答案:
1=>D 主题topicN的partitions0分区的相关信息在节点/kafka/brokers/topics/topicN/partitions/0/state
中保存,比如该分区的Leader是谁,isr列表等。