kafka基本命令使用

本文主要参考：http://kafka.apache.org/quickstart

最近开始接触kafka，下面介绍介绍一些最基本的kafka 的操作。

首先是启动kafka。kafka依赖zookeeper，所以需要先启动zookeeper。

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

然后启动kafka：

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

./kafka-server-start.sh -daemon ../config/server.properties
下面介绍在kafka中如何创建topic，查看topic以及消费topic。

1、查看topic

kafka-topics --list --zookeeper cdh4:2181,cdh5:2181,cdh6:2181

2、创建一个topic

kafka-topics --create --zookeeper cdh4:2181,cdh5:2181,cdh6:2181 --replication-factor 1 --partitions 1 --topic test

3、向topic中添加内容：

kafka-console-producer --broker-list cdh4:9002,cdh5:9092,cdh6:9092 --topic test

4、消费指定的topic：

kafka-console-consumer --zookeeper cdh4:2181,cdh5:2181,cdh6:2181 --topic test --from-beginning

kafka-console-consumer --bootstrap-server cdh4:9092,cdh5:9092:cdh6:9092 --topic test --from-beginning

5、查看堆积情况

./kafka-run-class.sh kafka.tools.ConsumerOffsetChecker -group myconsumergroup -topic mytopic -zookeeper localhost:2181

版权声明：本文来源CSDN，感谢博主原创文章，遵循 CC 4.0 by-sa 版权协议，转载请附上原文出处链接和本声明。
原文链接：https://blog.csdn.net/wild46cat/article/details/72860760
站方申明：本站部分内容来自社区用户分享，若涉及侵权，请联系站方删除。

发表于 2020-02-02 18:14:40
阅读 ( 1140 )
分类：

kafka基本命令使用

kafka基本命令使用

你可能感兴趣的文章

精选的优质文章

0 条评论

官方社群

GO教程

推荐文章

猜你喜欢

随便看看