vault backup: 2024-10-27 22:24:02

.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",

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]]
+![](./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)