Zookeeper内部信息 Kafka指令 消费逻辑 kafka的consumer是以什么为粒度更新&持久化offset的???
Zookeeper内部信息查看当前那个broker是controllerget /controller
ls /brokers
ls /brokers/topics 查看当前kafka 集群中的所有topic
Kafka指令kafka-topics.sh --zookeeper hadoop3:2181 --create --topi

Zookeeper内部信息 Kafka指令 消费逻辑 kafka的consumer是以什么为粒度更新&持久化offset的???
Zookeeper内部信息查看当前那个broker是controllerget /controller
ls /brokers
ls /brokers/topics 查看当前kafka 集群中的所有topic
Kafka指令kafka-topics.sh --zookeeper hadoop3:2181 --create --topi