博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
kafka入门学习---1 启动kakfa
阅读量:6420 次
发布时间:2019-06-23

本文共 855 字,大约阅读时间需要 2 分钟。

1.查看kafka生产者产生的数据

kafka-console-consumer.sh  --zookeeper hadoop-2:2181,hadoop-3:2181,hadoop-5:2181 -topic kafkademo --from-beginning

2.管道符命令。查看最进使用关于带有kafka关键字的命令

history|grep kafka

3.配置本机与远程机

tail -100 /usr/local/hadoop/hadoop-2.7.3/logs/hadoop-root-namenode-hadoop-4.out

 

1.kafka简单的消费命令

kafka-console-consumer.sh --zookeeper hadoop-2:2181,hadoop-3:2181,hadoop-5:2181 -topic kafkademo --from-beginning

 2.打印kafka所有的主题

kafka-topics.sh --zookeeper hadoop-2:2181 --list

 3.查看kafka最大的分区(Offset)

kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list hadoop-2:9092 -topic kafkademo --time -1

 1.启动kafak会提示 -bash: kafka-server-start.sh: command not found.这时就需要进入kafka的bin中启动.因为下面是脚本驱动的

 

kafka-server-start.sh /usr/local/kafka_2.11-0.10.0.1/config/server.properties > /usr/local/kafka_2.11-0.10.0.1/logs/logs &

 

 

转载于:https://www.cnblogs.com/kaiwen1/p/8549749.html

你可能感兴趣的文章
oVirt JBAS server start failed, ajp proxy cann't server correct. ovirt-engine URL cann't open
查看>>
CDP WebConsole上线公告
查看>>
ubuntu下安装摄像头应用程序xawtv
查看>>
GFS2,GFS,EXT2,EXT3 SEQ-write performance compare
查看>>
PostgreSQL 如何比较两个表的定义是否一致
查看>>
PHPCMS2008利用EXP
查看>>
扩展android-volley来开发Android restful client
查看>>
Linux Mint下Kindle Fire调试android程序
查看>>
自定义Background
查看>>
git笔记
查看>>
Android开源中国客户端学习 配置文件读写 以及其他一些工具类 <13>
查看>>
国外的opencv识别文档
查看>>
java获取指定字符串的下一个
查看>>
多行数据提交到Struts的ActionForm的List属性中
查看>>
理解RESTful架构
查看>>
Linux自动压缩备份目录文件与恢复
查看>>
Android 图片相关整理
查看>>
创建一个Hello World(React),组件的作用
查看>>
java中的context
查看>>
Spring源码阅读——3
查看>>