欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

Hbase,kafka,flume常用操作指令

程序员文章站 2022-05-15 13:48:38
...
启动hbase之前需要先启动ZK,前提是你安装的Hbase 集群采用的自己搭建的zk集群而不是使用Hbase自带的集群

zkServer.sh start

hbase 启动命令  start-hbase.sh  

----Hbase shell常用指令----

进入:hbase shell

//常用的shell 操作指令

list   ---列出当前所有的表

list_namespace ----列出表空间

list_namespce_tables '表空间名称'  -----列出当前表空间下面的表



kafka 启动命令:

[[email protected] kafka_2.11-2.3.0]# bin/kafka-server-start.sh config/server.properties

kafka 创建主题

[[email protected] kafka_2.11-2.3.0]# bin/kafka-topics.sh --zookeeper bigdata111:2181 --topic calllog --create --replication-factor 1 --partitions 3

选项说明:
--topic 定义topic名
--replication-factor  定义副本数
--partitions  定义分区数




kafka 查看集群创建的主题列表

[[email protected] kafka_2.11-2.3.0]# bin/kafka-topics.sh --bootstrap-server bigdata111:9092 bigdata112:9092 bigdata113:9092 --list

-------------------输出的结果---------------------
__consumer_offsets    
calllog

kafka 启动消费者

[[email protected] kafka_2.11-2.3.0]# bin/kafka-console-consumer.sh --bootstrap-server bigdata111:9092 --topic calllog --from-beginning


启动flume(flume 与 kafka 集成)

在conf下创建job文件夹
$ bin/flume-ng agent \
--conf conf/ \
--name a1 \
--conf-file conf/job/flume-telnet.conf -Dflume.root.logger==INFO,console

--简写

bin/flume-ng agent -n a1 -c conf -f jobs/flume-kafka.conf -Dflume.root.logger=INFO,console






 

相关标签: 常用指令