【Kafka】Apache Kafka消息队列Topic管理

旧城等待， 2023-10-05 12:26 5阅读 0赞

#### 指路牌 ####

*   *  Topic管理(集群)
     *   *  创建
         *  列表
         *  详情
         *  修改
         *  删除
         *  订阅
         *  消费组
         *  生产

### Topic管理(集群) ###

#### 创建 ####

[root@CentOSA kafka_2.11-2.2.0]# ./bin/kafka-topics.sh \
                        --bootstrap-server CentOSA:9092,CentOSB:9092,CentOSC:9092 
                        --create \
                        --topic topic02 \
                        --partitions 3 \
                        --replication-factor 3

#### 列表 ####

[root@CentOSA kafka_2.11-2.2.0]# ./bin/kafka-topics.sh \
                        --bootstrap-server CentOSA:9092,CentOSB:9092,CentOSC:9092 \
                        --list
    
    topic01
    topic02

#### 详情 ####

[root@CentOSA kafka_2.11-2.2.0]# ./bin/kafka-topics.sh \
                        --bootstrap-server CentOSA:9092,CentOSB:9092,CentOSC:9092 \
                        --describe \
                        --topic topic01
    
    Topic:topic01	PartitionCount:3	ReplicationFactor:3	Configs:segment.bytes=1073741824
    	Topic: topic01	Partition: 0	Leader: 0	Replicas: 0,2,3	Isr: 0,2,3
    	Topic: topic01	Partition: 1	Leader: 2	Replicas: 2,3,0	Isr: 2,3,0
    	Topic: topic01	Partition: 2	Leader: 0	Replicas: 3,0,2	Isr: 0,2,3

#### 修改 ####

[root@CentOSA kafka_2.11-2.2.0]# ./bin/kafka-topics.sh \
                        --bootstrap-server CentOSA:9092,CentOSB:9092,CentOSC:9092 \
                        --alter \
                        --topic topic03 \
                        --partitions 4 \

> 仅仅只允许用户增加topic的分区数，不允许减小

#### 删除 ####

[root@CentOSA kafka_2.11-2.2.0]# ./bin/kafka-topics.sh 
                        --bootstrap-server CentOSA:9092,CentOSB:9092,CentOSC:9092 
                        --delete 
                        --topic topic03

#### 订阅 ####

[root@CentOSA kafka_2.11-2.2.0]# ./bin/kafka-console-consumer.sh \
                      --bootstrap-server CentOSA:9092,CentOSB:9092,CentOSC:9092 \
                      --topic topic01 \
                      --group g1 \
                      --property print.key=true 
                      --property print.value=true 
                      --property key.separator=,

#### 消费组 ####

[root@CentOSA kafka_2.11-2.2.0]# ./bin/kafka-consumer-groups.sh \
                      --bootstrap-server CentOSA:9092,CentOSB:9092,CentOSC:9092 \
                      --list
                      g1
                      
    [root@CentOSA kafka_2.11-2.2.0]# ./bin/kafka-consumer-groups.sh 
                      --bootstrap-server CentOSA:9092,CentOSB:9092,CentOSC:9092 
                      --describe 
                      --group g1
    
    TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG CONSUMER-ID    HOST            CLIENT-ID
    topic01 1       0              0               0  consumer-1-** /192.168.52.130 consumer-1
    topic01 0       0              0               0  consumer-1-** /192.168.52.130 consumer-1
    topic01 2       1              1               0  consumer-1-** /192.168.52.130 consumer-1

#### 生产 ####

[root@CentOSA kafka_2.11-2.2.0]# ./bin/kafka-console-producer.sh \
                      --broker-list CentOSA:9092,CentOSB:9092,CentOSC:9092 \
                      --topic topic01