kafka-zk-安装测试初体验

Posted 2020-10-07 小蜗爬爬

第一步: 安装

 安装工具brew install kafka 会自动安装依赖zookeeper

 注：安装配置文件位置 /usr/local/etc/kafka|zookeeper

 

第二步: 启动

启动 zookeeper

cd /usr/local/Cellar/kafka/0.10.0.1

./bin/zookeeper-server-start  /usr/local/etc/kafka/zookeeper.properties &

启动kafka服务

./bin/kafka-server-start /usr/local/etc/kafka/server.properties &

注：『&』表示要挂到后台使用

 

第三步: 测试

1、创建topic 

./bin/kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test1

2、查看创建的topic

./bin/kafka-topics --list --zookeeper localhost:2181

3、生产数据

./bin/kafka-console-producer --broker-list localhost:9092 --topic test1

4、消费数据

./bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test1--from-beginning