kafka与zookeeper的安装和基本使用

时间:2020-12-07 05:55:29

1、zookeeper的安装

下载后解压,在指定的位置创建data文件夹和log文件夹,用来存储zookeeper的信息,在data文件夹下创建一个myid的文件,里面输入内容1

将conf里面的zoo_example.cfg修改为zoo.cfg,然后编辑里面的内容,一个是dataDir位置修改为刚才的data文件夹位置,logDataDir修改为刚才的log文件夹位置

里面的port默认为2181,可以不修改

2、kafka的安装

下载解压后,编辑config里面的server.properties,将zookeeper选项修改为刚才zk的配置项,logDir修改为自己创建的log文件夹,brokerid要设唯一

3、zookeeper与kafka的使用

要先启动zookeeper,启动命令为./zkServer.sh ../conf/zoo.cfg,查看是否启动可以使用jps命令,有QuorumPeerMain即可

然后再启动kafka,启动命令为./kafka-server-start.sh ../config/server.properties (一定要 先启动服务再创建topic,如果ip地址变化,server.properties里面的advised.host.name也要修改)

创建topic,命令为./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test (test为topic的名字)

创建生产者,命令为./kafka-console-producer.sh --broker-list localhost:9092 --topic test

重新开一个窗口创建消费者,命令为./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

然后就可以在生产者中发送消息,在消费者中接收到消息