kafka配置与命令行

几个配置的解释

auto-offset-reset

一般对于auto-offset-reset的解释就是: 当各分区下有已提交的offset时，从提交的offset开始消费；无提交的offset时，从头开始消费.
这里有一个隐藏的语境没有说明: 该配置是针对于对于新加入的consumer来说的. 如果一个consumer已经有offset了, 那就是从原offset开始. 否则, 才会配置该consumer的offset在earliest还是所有consumer中的latest, 亦或是报错.

##

常用命令行

# 重置offset
./bin/kafka-consumer-groups.sh --bootstrap-server 172.20.240.106:9092  --group zink-20220617  --reset-offsets   --to-offset 0  --execute --topic show
./bin/kafka-consumer-groups.sh --bootstrap-server 172.20.240.106:9092  --group zink-20220617  --reset-offsets   --to-earliest  --execute --topic show

# 查看consumer信息
./bin/kafka-consumer-groups.sh --bootstrap-server 172.20.240.106:9092  --group zink  --describe

# 调整partition
./bin/kafka-topics.sh --bootstrap-server 172.20.240.106:9092 --topic show --alter --partitions 2

# 查看topic信息
./bin/kafka-topics.sh --bootstrap-server 172.20.240.106:9092 --topic show --describe

# 删除topic
./bin/kafka-topics.sh --delete --bootstrap-server zk1:9092 --topic quickstart-events