连接kafka时需要输入kafka节点名和端口:
例如:
kafka-topics.sh –bootstrap-server hadoop102:9092 –list
kafka-topics.sh –bootstrap-server hadoop102:9092,haddoop103:9092,hadoop104:9092 –list
这两种的启动效果是一样的,都是连接kafka集群。
有人会问:kafka集群有leader和follower,为什么不直接连接kafka集群?
无论连接哪个broker,都会从leader所在进行访问,在这里就不得不说kafka集群中leader和follower的作用,简单的介绍一下:
1.leader主要是面对生产者和消费者,对数据的读入和写出,follower主要是同步leader所在节点的数据。
2.在kafka集群中哪个broker节点先启动,那个broker就是leader.