diff --git a/.obsidian/workspace.json b/.obsidian/workspace.json index 262f5f1..575351f 100644 --- a/.obsidian/workspace.json +++ b/.obsidian/workspace.json @@ -13,7 +13,7 @@ "state": { "type": "markdown", "state": { - "file": "Spark搭建/spark-streaming.md", + "file": "Kafka/3.Customer.md", "mode": "source", "source": false } @@ -85,7 +85,7 @@ "state": { "type": "backlink", "state": { - "file": "Spark搭建/spark-streaming.md", + "file": "Kafka/3.Customer.md", "collapseAll": false, "extraContext": false, "sortOrder": "alphabetical", @@ -102,7 +102,7 @@ "state": { "type": "outgoing-link", "state": { - "file": "Spark搭建/spark-streaming.md", + "file": "Kafka/3.Customer.md", "linksCollapsed": false, "unlinkedCollapsed": true } @@ -125,7 +125,7 @@ "state": { "type": "outline", "state": { - "file": "Spark搭建/spark-streaming.md" + "file": "Kafka/3.Customer.md" } } }, @@ -157,26 +157,32 @@ }, "active": "a6359902bf66f6d5", "lastOpenFiles": [ - "Spark搭建/liu.md", - "Spark搭建/spark-streaming.md", - "README.md", - "Spark搭建/spark-sql.md", - "Spark搭建/scala与rdd编程.md", + "Kafka/assert/2.png", + "Kafka/assert/2.png", + "Kafka/3.Customer.md", + "Kafka/assert/1.png", + "HaiNiuHadoop搭建/2.ZooKeeper配置.md", + "HaiNiuHadoop搭建/未命名.md", + "HaiNiuHadoop搭建/4.Yarn配置.md", + "HaiNiuHadoop搭建/3.HDFS搭建.md", + "HaiNiuHadoop搭建/1.环境安装.md", + "Kafka/assert", "未命名.md", + "Kafka", + "Spark搭建/scala与rdd编程.md", + "Spark搭建/spark-sql.md", + "Spark搭建/spark-streaming.md", + "Spark搭建/liu.md", + "README.md", "Spark搭建/01.md", "README.md.md", "Spark搭建/images/workers.png", - "HaiNiuHadoop搭建/1.环境安装.md", "HaiNiuHadoop搭建/images/000001.png", "2024-09-18.md", "欢迎.md", "2024-09-04.md", "Hadoop/Zookeeper.md", "Hadoop/HDFS搭建.md", - "HaiNiuHadoop搭建/2.ZooKeeper配置.md", - "HaiNiuHadoop搭建/未命名.md", - "HaiNiuHadoop搭建/4.Yarn配置.md", - "HaiNiuHadoop搭建/3.HDFS搭建.md", "Spark搭建/images", "Spark搭建", "HaiNiuHadoop搭建/Yarn配置.md", diff --git a/Kafka/3.Customer.md b/Kafka/3.Customer.md new file mode 100644 index 0000000..3234c31 --- /dev/null +++ b/Kafka/3.Customer.md @@ -0,0 +1,12 @@ +### kafka的数据结构 +查看数据日志文件信息 +```bash +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/2.png]] \ No newline at end of file diff --git a/Kafka/assert/1.png b/Kafka/assert/1.png new file mode 100644 index 0000000..84e7288 Binary files /dev/null and b/Kafka/assert/1.png differ diff --git a/Kafka/assert/2.png b/Kafka/assert/2.png new file mode 100644 index 0000000..7966040 Binary files /dev/null and b/Kafka/assert/2.png differ