1+X中级A卷:kafka集群

第一步 先解压上传的kafka压缩包 [root@zookeeper1 ~]# tar -zxvf kafka_2.11-1.1.1.tgz kafka_2.11-1.1.1/ kafka_2.11-1.1.1/LICENSE kafka_2.11-1.1.1/NOTICE kafka_2.11-1.1.1/bin/ kafka_2.11-1.1.1/bin/kafka-preferred-replica-election.sh kafka_2.11-1.1.1/bin/connect-standalone.sh kafka_2.11-1.1.1/bin/kafka-server-start.sh kafka_2.11-1.1.1/bin/windows/ kafka_2.11-1.1.1/bin/windows/zookeeper-server-stop.bat kafka_2.11-1.1.1/bin/windows/zookeeper-shell.bat kafka_2.11-1.1.1/bin/windows/kafka-console-producer.bat kafka_2.11-1.1.1/bin/windows/kafka-console-consumer.bat kafka_2.11-1.1.1/bin/windows/connect-standalone.bat

[root@zookeeper2 ~]# tar -zxvf kafka_2.11-1.1.1.tgz kafka_2.11-1.1.1/ kafka_2.11-1.1.1/LICENSE kafka_2.11-1.1.1/NOTICE kafka_2.11-1.1.1/bin/ kafka_2.11-1.1.1/bin/kafka-preferred-replica-election.sh kafka_2.11-1.1.1/bin/connect-standalone.sh kafka_2.11-1.1.1/bin/kafka-server-start.sh kafka_2.11-1.1.1/bin/windows/ kafka_2.11-1.1.1/bin/windows/zookeeper-server-stop.bat kafka_2.11-1.1.1/bin/windows/zookeeper-shell.bat kafka_2.11-1.1.1/bin/windows/kafka-console-producer.bat kafka_2.11-1.1.1/bin/windows/kafka-console-consumer.bat kafka_2.11-1.1.1/bin/windows/connect-standalone.bat

[root@zookeeper3 ~]# tar -zxvf kafka_2.11-1.1.1.tgz kafka_2.11-1.1.1/ kafka_2.11-1.1.1/LICENSE kafka_2.11-1.1.1/NOTICE kafka_2.11-1.1.1/bin/ kafka_2.11-1.1.1/bin/kafka-preferred-replica-election.sh kafka_2.11-1.1.1/bin/connect-standalone.sh kafka_2.11-1.1.1/bin/kafka-server-start.sh kafka_2.11-1.1.1/bin/windows/ kafka_2.11-1.1.1/bin/windows/zookeeper-server-stop.bat kafka_2.11-1.1.1/bin/windows/zookeeper-shell.bat kafka_2.11-1.1.1/bin/windows/kafka-console-producer.bat kafka_2.11-1.1.1/bin/windows/kafka-console-consumer.bat kafka_2.11-1.1.1/bin/windows/connect-standalone.bat

第二步 修改三个节点的配置文件 [root@zookeeper1 ~]# cd kafka_2.11-1.1.1/config/ [root@zookeeper1 config]# vi server.properties

[root@zookeeper2 ~]# cd kafka_2.11-1.1.1/config/ [root@zookeeper2 config]# vi server.properties

[root@zookeeper3 ~]# cd kafka_2.11-1.1.1/config/ [root@zookeeper3 config]# vi server.properties

第三步 启动服务 [root@zookeeper1 bin]# ./kafka-server-start.sh -daemon[root@zookeeper1 bin]# ./kafka-server-start.sh -daemon ../config/server.properties [root@zookeeper1 bin]# jps 6917 Kafka 5992 QuorumPeerMain 6943 Jps

[root@zookeeper2 bin]# ./kafka-server-start.sh -daemon[root@zookeeper1 bin]# ./kafka-server-start.sh -daemon ../config/server.properties [root@zookeeper2 bin]# jps

[root@zookeeper3 bin]# ./kafka-server-start.sh -daemon[root@zookeeper1 bin]# ./kafka-server-start.sh -daemon ../config/server.properties [root@zookeeper3 bin]# jps

测试服务 [root@ zookeeper1bin]#./kafka-topics.sh --create --zookeeper 192.168.200.40:2181 --replication-factor 1 --partitions 1 --topic test

Created topic "test". 出现created topic “test”显示成功