栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 前沿技术 > 大数据 > 大数据系统

linux安装kafka

linux安装kafka

    首先进入官网下载kafka将下载的kafka压缩包 放入linux服务器的指定目录解压kafka 命令 tar -xzf kafka_2.12-3.1.0.tgz进入kafka目录命令 cd kafka_2.12-3.1.0/启动zookeeper命令 bin/zookeeper-server-start.sh config/zookeeper.properties 这个是 窗口模式,后台启动zookeeper命令 bin/zookeeper-server-start.sh config/zookeeper.properties 1>/dev/null 2>&1 & 或者 bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
    -daemon:表示以守护进程的方式启动。启动kafka命令 bin/kafka-server-start.sh config/server.properties 这个是 窗口模式,后台启动kafka命令 bin/kafka-server-start.sh config/server.properties 1>/dev/null 2>&1 & 或者 bin/kafka-server-start.sh -daemon config/server.properties测试端口 kafka默认端口9092 查看9092端口是否有信息 lsof -i:9092 如果有信息说明 启动成功测试 创建一个主题命令 (旧版)bin/kafka-topics.sh --create --zookeeper localhost:2181–replication-factor 1 --partitions 1 --topic test
    (新版)bin/kafka-topics.sh --bootstrap-server localhost:9092 --create --replication-factor 1 --partitions 1 --topic test查看当前zk中所有的topic命令 bin/kafka-topics.sh --list --zookeeper localhost:2181 或者 bin/kafka-topics.sh --list --bootstrap-server localhost:9092,就是显示在第8步创建成功的 test, 说明kafka安装成功 可以使用 下面的步骤可以忽略,也可以测试测试生产者 bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test 随便输入一下数据然后在另一个终端中,启动consumer命令 bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning 就会显示刚刚输入的数据查看topic详情 bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic test删除topic bin/kafka-topics.sh --delete --zookeeper localhost:2181 -topic test
转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/780201.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号