Mac OS启动Kafka

719 0 0

作者:Mysticbinary

kafka目录结构

# kafka安装目录
/usr/local/Cellar/kafka/2.6.0

# 配置文件目录
/usr/local/etc/kafka/

# 如果超时，在server.properties中增加
zookeeper.connection.timeout.ms=6000000

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

检测是否启动成功
ps aux | grep zookeeper

（上图为启动成功时截图）

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

检测是否启动成功
ps aux | grep kakfka

kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic basket_test

查看topic list
kafka-topics --list --zookeeper localhost:2181

要是报：Timed out waiting for connection while in state: CONNECTING ，那就是没有启动zk、kafka

kafka-console-producer --broker-list localhost:9092 --topic basket_test

进入指定生产者
kafka-console-producer --broker-list localhost:9092 --topic basket_test

kafka-console-consumer --bootstrap-server localhost:9092 --topic basket_test --from-beginning

内容来源于网络如有侵权请私信删除

文章来源: 博客园

标签：大数据大数据技术文章

你还没有登录，请先登录或注册！