启动
Kafka 自带了一个启动KafkaServer 的脚本kafka-server-start.sh
| 名称 | 作用 |
|---|---|
| /consumers | 旧版消费者启动后会在ZooK臼P町的该节点路径下创建一个消费组的节点。 |
| /brokers/seq id | 辅助生成代理的id，当用户没有配置broker.id 时， ZooKe叩er 会自动生成一个全局唯一的M，每次自动生成时会从该路由读取当前代理的id 最大值，然后加l |
| /brokers/topics | 每创建一个主题时就会在该目录下创建一个与主题同名的节点 |
| /brokers/ids | 当Kafka 每启动一个KafkaServer 时会在该目录下创建一个名为$｛ broker.id}的子节点 |
| /config, topics | 存储动态修改主题级别的配置信息 |
| /config/clients | 存储动态修改客户端级别的配置信息 |
| /config/changes | 动态修改配置时存储相应的信息， |
| /admin/delete topics | 在对主题进行删除操作时保存待删除主题的信息 |
| /cluster/id | 保存集群id 信息 |
| /controller | 保存控制器对应的brokerld 信息等 |
| /isr change notification | 保存Kafka 副本ISR 列表发生变化时通知的相应路径 |
创建主题
kafka-topics.sh 脚本
分区副本分配
生产者
kafka-conso le-producer. sh