码迷,mamicode.com
首页 > 其他好文 > 详细

kafka常用命令,启动/停止/查看主题列表/消费/生产

时间:2020-06-08 12:58:18      阅读:252      评论:0      收藏:0      [点我收藏+]

标签:bashrc   cer   top   art   load   生效   ati   ima   int   

kafka启动(需要先启动zk):

bin/zookeeper-server-start.sh -daemon config/zookeeper.properties 
bin/kafka-server-start.sh -daemon config/server.properties 

 

kafka停止:

bin/kafka-server-stop.sh 
bin/zookeeper-server-stop.sh 

 

把以下内容追加到bashrc中。

以centos为例:

vi ~/.bashrc

追加内容如下:

KAFKA_HOME="/usr/lib/kafka"
KAFKA_ADDRESS="192.168.108.136"
KAFKA_BIND="${KAFKA_ADDRESS}:9092"
ZK_BIND="${KAFKA_ADDRESS}:2181"

alias listtopics="${KAFKA_HOME}/bin/kafka-topics.sh --list --zookeeper ${ZK_BIND} "
alias createtopic="${KAFKA_HOME}/bin/kafka-topics.sh --create --zookeeper ${ZK_BIND} --replication-factor 1 --partitions 1 --topic "
alias kafkaproduce="${KAFKA_HOME}/bin/kafka-console-producer.sh --broker-list ${KAFKA_BIND} --topic "
alias kafkaconsume="${KAFKA_HOME}/bin/kafka-console-consumer.sh --zookeeper ${ZK_BIND} --from-beginning --topic "
alias kafkaconsumekey="${KAFKA_HOME}/bin/kafka-console-consumer.sh --zookeeper ${ZK_BIND} --from-beginning --property print.key=true --property key.separator=‘ --- ‘ --topic "
alias kafkaconsumeoffset="${KAFKA_HOME}/bin/kafka-console-consumer.sh --zookeeper ${ZK_BIND} --from-beginning --print-offsets --topic"

技术图片

 

保存后使其生效

source ~/.bashrc

 

查看kafka主题:

listtopics

创建kafka主题parasis:

createtopic parasis

在parasis主题下生产数据,进入命令行后,输入生产数据,以回车结尾:

kafkaproduce parasis

消费parasis主题内数据:

kafkaconsume parasis

消费parasis主题内数据(包含key):

kafkaconsumekey parasis

消费parasis主题内数据(包含offset):

kafkaconsumeoffset parasis

 

kafka常用命令,启动/停止/查看主题列表/消费/生产

标签:bashrc   cer   top   art   load   生效   ati   ima   int   

原文地址:https://www.cnblogs.com/parasis/p/13064667.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!