kafka常用基本命令 topic主题操作kafka-topics.sh，生产消息，消费消息，查看消费者组消费情况kafka-consumer-groups.sh等_kafkaserver id=1002 这编号1002编号代表什么意思

选项说明：
--topic 定义 主题名
--partitions 定义分区数
--replication-factor 定义副本数
 
 
创建主题
kafka-topics.sh --create --bootstrap-server localhost:9092 --topic xinwen --partitions 3 --replication-factor 3
 
列出所有主题
kafka-topics.sh --list --bootstrap-server localhost:9092
 
查看主题详情
kafka-topics.sh --describe --bootstrap-server localhost:9092 --topic xinwen
 
修改主题配置
kafka-topics.sh --alter --topic xinwen --partitions 10 --bootstrap-server localhost:9092
 
删除主题
kafka-topics.sh --delete --bootstrap-server localhost:9092 --topic xinwen

查看指定的topic明细，关注下ISR
kafka-topics.sh --bootstrap-server localhost:9092 --describe --topic zhuti_1

//说明
Topic:主题
PartitionCount:分区的数量，这里为2个，下标是从0开始的，物理上的分区
ReplicationFactor:副本的数量，指的是一个分区被复制成几份
下面的 1001，1002是 broker.id 属性设置的
Leader: 1002  指的是broker.id=1002  Leader负责读和写
Replicas: 复制该分区数据的节点列表，第一位代表leader  [静态表述]
Isr: in-sync Replicas 正在复制的副本节点列表          [动态表述]
     当leader挂了，会从这个列表选举出leader
 
Topic:zhuti_1   PartitionCount:2        ReplicationFactor:2     Configs:
Topic: zhuti_1  Partition: 0    Leader: 1002    Replicas: 1002,1001     Isr: 1001,1002
Topic: zhuti_1  Partition: 1    Leader: 1003    Replicas: 1003,1002     Isr: 1003,1002

删除topic
kafka-topics.sh --bootstrap-server localhost:9092 --delete --topic zhuti_1
注：默认情况下，不能真正删除topic，只是把这个topic标记为删除（marked for deletion），
要彻底把topic删除，先修改kafka安装目录下config/server.properties文件中的属性delete.topic.enable=true，
必须把kafka中与当前topic相关的数据目录和zookeeper中与当前topic相关的路径一并删除

生产消息和消费消息

生产消息
kafka-console-producer.sh --bootstrap-server localhost:9092 --topic xinwen
 
从头开始消费,从主题最开始的消息开始消费
kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic xinwen --from-beginning
 
实时消费,只想消费新产生的消息，即实时消费
kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic xinwen

消费者组消费情况

查看所有消费者组
kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list
 
查看特定消费者组的详细信息
kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group group_1
 
# 重置到最早的偏移量,从头开始消费
kafka-consumer-groups.sh --bootstrap-server localhost:9092 --reset-offsets --to-earliest --execute --group group_1 --topic xinwen
 
# 重置到最晚的偏移量,从最新的消息的下一条开始消费
kafka-consumer-groups.sh --bootstrap-server localhost:9092 --reset-offsets --to-latest --execute --group group_1 --topic xinwen

下面两张图是演示重置消费者组offset偏移量的情况
重点观察 CURRENT-OFFSET 和 LAG ，LAG为0，表示已经消费到最新的位置了