【云原生进阶之PaaS中间件】第三章Kafka-3-命令操作
【云原生进阶之PaaS中间件】第三章Kafka-3-命令操作
1 命令操作
1.1 主题命令操作
查看操作主题命令参数：
[atguigu@hadoop102 kafka]$ bin/kafka-topics.sh参数描述
--bootstrap-server，连接的Kafka Broker主机名称和端口号。
--topic，操作的topic名称。
--create，创建主题。
--delete，删除主题。
--alter，修改主题。
--list，查看所有主题。
--describe，查看主题详细描述。
--partitions，设置分区数。
--replication-factor，设置分区副本。
--config，更新系统默认的配置。
（1）查看服务器中的topic
[atguigu@hadoop102 kafka]$ kafka-topics.sh --bootstrap-server hadoop102:9092 --list（2）创建first topic
[atguigu@hadoop102 kafka]$ kafka-topics.sh --bootstrap-server hadoop102:9092 --create --partitions 3 --replication-factor 2 --first topic选项说明：
--topic 定义topic名
--replication-factor 定义副本数
--partitions 定义分区数
（3） 查看first主题详情
[atguigu@hadoop102 kafka]$ kafka-topics.sh --bootstrap-server hadoop102:9092 --describe --first topic（4）修改分区数（分区数只能增加，不能减少）
[atguigu@hadoop102 kafka]$ kafka-topics.sh --bootstrap-server hadoop102:9092 --alter --first topic --partition 5（5）删除topic
[atguigu@hadoop102 kafka]$ kafka-topics.sh --bootstrap-server hadoop102:9092 --delete --first topic1.2 生产者命令操作
查看操作生产者命令
[atguigu@hadoop102 kafka]$ kafka-console-producer.sh参数描述
--bootstrap-server，连接的Kafka Broker主机名称和端口号。
--topic，操作的topic名称。
发送消息
[atguigu@hadoop102 kafka]$ kafka-console-producer.sh --bootstrap-server hadoop102:9092 --topic first1.3 消费者命令操作
查看操作消费者命令
[atguigu@hadoop102 kafka]$ kafka-console-consumer.sh参数描述
--bootstrap-server，连接的Kafka Broker主机名称和端口号。
--topic，操作的topic名称。
--from-beginning，从头开始消费。
--group，指定消费者组名称。
????????消费主题first中的信息(从末尾开始）
[atguigu@hadoop102 kafka]$ kafka-console-consumer.sh --bootstrap-server hadoop102:9092 --topic first????????把主题中所有的数据都读取出来（包括历史数据）
[atguigu@hadoop102 kafka]$ kafka-console-consumer.sh --bootstrap-server hadoop102:9092 --from beginning --topic first????????命令行中使用的消费者，如果不写消费者组，系统会默认分配一个随机的消费者组。所以每次启动都无法消费之前的数据。添加--from-beginning 可以从头消费。
????????如果是同一个组的消费者 ，能实现断点续传的功能。添加--from-beginning 也还是断点续传的。
????????如果生产消费到一个不存在的主题，系统会自动帮你创建这个主题，分区和副本的个数都为1个。
参考链接
【精选】Kafka基本原理详解_昙花逐月的博客-CSDN博客