白眉大叔 kafka topic管理命令
kafka topic管理:
- 增:
创建一个名为"baimei-dashu87"的topic，分区数为3。
kafka-topics.sh --bootstrap-server 10.0.0.111:9092,10.0.0.112:9092 --create --topic baimei-dashu87 --partitions 3
创建一个名为"baimei-dashu87"的topic，分区数为3，副本数为2。
kafka-topics.sh --bootstrap-server 10.0.0.111:9092,10.0.0.112:9092 --create --topic baimei-dashu88 --partitions 3 --replication-factor 2- 查
查看topic列表。
kafka-topics.sh --bootstrap-server 10.0.0.111:9092,10.0.0.112:9092 --list
查看所有topic的详细信息。
kafka-topics.sh --bootstrap-server 10.0.0.111:9092,10.0.0.112:9092 --describe查看指定topic的详细信息。
kafka-topics.sh --bootstrap-server 10.0.0.111:9092,10.0.0.112:9092 --describe --topic baimei-dashu86- 改
将"baimei-dashu86"的topic分区数增加为5个。
kafka-topics.sh --bootstrap-server 10.0.0.111:9092,10.0.0.112:9092 --alter --topic baimei-dashu86 --partitions 5
副本数修改可参考连接:
https://www.cnblogs.com/baimei/p/9808125.html
生产环境中:
分区数20，副本数为2，broker节点5个。硬件配置：32c 32G 8T*12
- 删
删除名为"baimei-dashu87"的topic。
kafka-topics.sh --bootstrap-server 10.0.0.111:9092,10.0.0.112:9092 --delete --topic baimei-dashu87生产者和消费者:
- 启动生产者:
kafka-console-producer.sh --bootstrap-server 10.0.0.111:9092 --topic baimei-dashu86 
- 启动消费者:
表示从最新的offset拉取数据。
kafka-console-consumer.sh --bootstrap-server 10.0.0.112:9092 --topic baimei-dashu86
表示从头开始拉取数据。
kafka-console-consumer.sh --bootstrap-server 10.0.0.112:9092 --topic baimei-dashu86 --from-beginning
欢迎来撩 ： 汇总all
