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