设为首页 加入收藏

TOP

Mac中kafka2.1.0安装和测试
2019-04-15 14:20:08 】 浏览:40
Tags:Mac kafka2.1.0 安装 测试
版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/zhangvalue/article/details/85841736

kafka的安装,在安装kafka会将其依赖的zookeeper下载

brew install kafka

进入到/usr/local/Cellar 路径之下会看见软件位置

/usr/local/Cellar/zookeeper

/usr/local/Cellar/kafka

其中的配置文件都在kafka路径之下的config 目录里面

/usr/local/Cellar/kafka/config

启动zookeeper

zookeeper-server-start /usr/local/Cellar/kafka/2.1.0/libexec/config/zookeeper.properties &

启动kafka服务

kafka-server-start /usr/local/Cellar/kafka/2.1.0/libexec/config/server.properties &

创建topic zhang

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


ht="136" src="https://img-blog.csdnimg.cn/20190105115505325.png" width="1200">

查看创建的topic

kafka-topics --list --zookeeper localhost:2181

生产者生产数据

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

消费者消费数据

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


编程开发网
】【打印繁体】【投稿】【收藏】 【推荐】【举报】【评论】 【关闭】 【返回顶部
上一篇vertica-->kafka-->mongodb.. 下一篇Kafka史上最详细原理总结   ..

评论

帐  号: 密码: (新用户注册)
验 证 码:
表  情:
内  容:

array(4) { ["type"]=> int(8) ["message"]=> string(24) "Undefined variable: jobs" ["file"]=> string(32) "/mnt/wp/cppentry/do/bencandy.php" ["line"]=> int(217) }