diff --git a/.obsidian/workspace.json b/.obsidian/workspace.json index 575351f..7d6345c 100644 --- a/.obsidian/workspace.json +++ b/.obsidian/workspace.json @@ -155,8 +155,10 @@ "obsidian-git:Open Git source control": false } }, - "active": "a6359902bf66f6d5", + "active": "c615f431a27fc4e9", "lastOpenFiles": [ + "Kafka/assert/4.png", + "Kafka/assert/3.png", "Kafka/assert/2.png", "Kafka/assert/2.png", "Kafka/3.Customer.md", diff --git a/Kafka/3.Customer.md b/Kafka/3.Customer.md index 3234c31..f6d71d8 100644 --- a/Kafka/3.Customer.md +++ b/Kafka/3.Customer.md @@ -6,7 +6,21 @@ kafka-dump-log.sh --print-data-log --files 00000000000000000000.log kafka-run-class.sh kafka.tools.DumpLogSegments --print-data-log --files 00000000000000000000.log ``` -![[./assert/1.png]] +![](./assert/1.png) ### 消费者的结构 -![[./assert/2.png]] \ No newline at end of file +![](./assert/2.png) +### 消费者分区的分配规则 +![](./assert/3.png) + +### Kafka的偏移量 +- 查看消费组的情况 +```bash +kafka-consumer-groups --bootstrap-server localhost:9092 --list +kafka-consumer-groups --bootstrap-server localhost:9092 --describe --group aisi-group +kafka-console-consumer --bootstrap-server localhost:9092 --topic __consumer_offsets --from-beginning --formatter kafka.coordinator.group.GroupMetadataManager\$OffsetsMessageFormatter + +# 重置消费者组对topic消费的offset +kafka-consumer-groups --bootstrap-server localhost:9092 --group aisi-group-01 --reset-offsets --to-earliest --all-topics --execute +``` +![](./assert/4.png) \ No newline at end of file diff --git a/Kafka/assert/3.png b/Kafka/assert/3.png new file mode 100644 index 0000000..ec8ef77 Binary files /dev/null and b/Kafka/assert/3.png differ diff --git a/Kafka/assert/4.png b/Kafka/assert/4.png new file mode 100644 index 0000000..8803a2b Binary files /dev/null and b/Kafka/assert/4.png differ