kafka常用命令

Posted

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了kafka常用命令相关的知识,希望对你有一定的参考价值。

到kafka目录下面执行命令:
nohup /usr/soft/kafka/kafka-server-start.sh
/usr/soft/kafka/config/server.properties &
 注意:会把生成的日志存放在nohup.out下面

下面的这种方式更好:
 /usr/soft/kafka/bin/kafka-server-start.sh /usr/soft/kafka/config/server.properties > /dev/null 2>&1 &
把标准输出和错误输出都写到了/dev/null中去了,/dev/null里面写什么都是空的。

//创建topic
/usr/soft/kafka/bin/kafka-topics.sh --zookeeper COS001:2181,COS002:2181,COS003:2181 --topic myTopic --replication-factor 2 --partitions 3 --create
/usr/soft/kafka/bin/kafka-topics.sh --create --zookeeper COS001:2181 --replication-factor 1 --partitions 1 --topic customerlog
/usr/soft/kafka/bin/kafka-topics.sh --create --zookeeper hadoop01:2181 --replication-factor 1 --partitions 3 --topic gamelog1


//查看当前服务器中的所有topic
/usr/soft/kafka/bin/kafka-topics.sh --list --zookeeper hadoop01:2181

//?查看某个Topic的详情
/usr/soft/kafka/bin/kafka-topics.sh --topic myTopic --describe --zookeeper mini1:2181

//?删除topic
/usr/soft/kafka/bin/kafka-topics.sh --delete --zookeeper hadoop01:2181 --topic myTopic
需要server.properties中设置delete.topic.enable=true否则只是标记删除或者直接重启。


##客户日志生产者##
./bin/kafka-console-producer.sh --broker-list hadoop01:9092 --topic gamelog

##客户日志消费者##
/usr/soft/kafka/bin/kafka-console-consumer.sh --zookeeper hadoop01:2181 --from-beginning --topic gamelog

以上是关于kafka常用命令的主要内容,如果未能解决你的问题,请参考以下文章

Kafka 常用命令行操作

一 Kafka介绍及常用命令行

Kafka常用命令合集

kafka常用的shell命令

kafka常用命令

kafka之常用命令