Kafka快速入门(命令行操作)
Kafka 命令行操作
Kafka基础架构
主题命令行操作
1)查看操作主题命令参数
bin/kafka-topics.sh
-参数 | -描述 |
---|---|
–bootstrap-server <String: server toconnect to> | 连接的 Kafka Broker 主机名称和端口号。 |
–topic <String: topic> | 操作的 topic 名称。 |
–create | 创建主题。 |
–delete | 删除主题。 |
–alter | 修改主题。 |
–list | 查看所有主题。 |
–describe | 查看主题详细描述。 |
–partitions <Integer: # of partitions> | 设置分区数。 |
–replication-factor<Integer: replication factor> | 设置分区副本。 |
–config <String: name=value> | 更新系统默认的配置。 |
2)查看当前服务器中的所有 topic
bin/kafka-topics.sh --bootstrap-server ip:9092 --list
3)创建 first topic
bin/kafka-topics.sh --bootstrap-server ip:9092 --create --partitions 1 --replication-factor 3 --topic first
选项说明:
- topic 定义 topic 名
- replication-factor 定义副本数
- partitions 定义分区数
4)查看 first 主题的详情
bin/kafka-topics.sh --bootstrap-server ip:9092 --describe --topic first
5)修改分区数(注意:分区数只能增加,不能减少)
bin/kafka-topics.sh --bootstrap-server ip:9092 --alter --topic first --partitions 3
6)再次查看 first 主题的详情
bin/kafka-topics.sh --bootstrap-server ip:9092 --describe --topic first
7)删除 topic
bin/kafka-topics.sh --bootstrap-server ip:9092 --delete --topic first
生产者命令行操作
1)查看操作生产者命令参数
bin/kafka-console-producer.sh
-参数 | -描述 |
---|---|
–bootstrap-server <String: server toconnect to> | 连接的 Kafka Broker 主机名称和端口号。 |
–topic <String: topic> | 操作的 topic 名称。 |
2)发送消息
bin/kafka-console-producer.sh --bootstrap-server ip:9092 --topic first
>hello world
消费者命令行操作
1)查看操作消费者命令参数
bin/kafka-console-consumer.sh
-参数 | -描述 |
---|---|
–bootstrap-server <String: server toconnect to> | 连接的 Kafka Broker 主机名称和端口号。 |
–topic <String: topic> | 操作的 topic 名称。 |
–from-beginning | 从头开始消费。 |
–group <String: consumer group id> | 指定消费者组名称。 |
2)消费消息
(1)消费 first 主题中的数据。
bin/kafka-console-consumer.sh --bootstrap-server ip:9092 --topic first
(2)把主题中所有的数据都读取出来(包括历史数据)。
bin/kafka-console-consumer.sh --bootstrap-server ip:9092 --from-beginning --topic first
取出来(包括历史数据)。
bin/kafka-console-consumer.sh --bootstrap-server ip:9092 --from-beginning --topic first
笔记来自b站尚硅谷
相关文章
- 数据孤岛是业务效率的无声杀手
- 2023展望:新的一年将给大数据分析领域带来什么?
- 阿里云ADB基于Hudi构建Lakehouse的实践
- 大数据在医疗保健领域的使用案例
- 微软增加说明:KB5021751 更新扫描已经 / 即将过时 Office 过程中不会触碰用户隐私
- 2022 Gartner全球云数据库管理系统魔力象限发布 腾讯云数据库入选
- 场景化、重实操,分享一个实时数仓实践案例
- Arctic的湖仓一体践行之路
- 分布式计算MapReduce究竟是怎么一回事?
- 淘系数据模型治理优秀实践
- 大数据分析对医疗保健的影响
- 当我们说大数据Hadoop,究竟在说什么?
- 2022年及以后大数据的五个发展趋势
- 网易严选离线数仓治理实践
- 2023 年数据治理趋势
- 一份“靠谱”的年度经营计划,你学会了吗?
- 漫谈对大数据的思考
- 测试一下,读懂数据的能力,你有吗?
- 用艺术的眼光探索数据之美
- 聊聊数据分析成果如何落地