vault backup: 2024-08-26 13:49:55

.obsidian/plugins/home-tab/data.json

@@ -23,6 +23,10 @@
   "markdownOnly": false,
   "unresolvedLinks": false,
   "recentFilesStore": [
+    {
+      "filepath": "_inbox/2024-08-26 1724669040.md",
+      "timestamp": 1724669040638
+    },
     {
       "filepath": "_inbox/Kafka Topic Partition.md",
       "timestamp": 1724668117126
@@ -38,10 +42,6 @@
     {
       "filepath": "_inbox/00 Kafka.md",
       "timestamp": 1724667944406
-    },
-    {
-      "filepath": "_inbox/Запуск Kafka в docker-compose.md",
-      "timestamp": 1724667335922
     }
   ],
   "bookmarkedFileStore": [],

.obsidian/plugins/recent-files-obsidian/data.json

@@ -1,5 +1,9 @@
 {
   "recentFiles": [
+    {
+      "basename": "Kafka Offset",
+      "path": "_inbox/Kafka Offset.md"
+    },
     {
       "basename": "Kafka Topic Partition",
       "path": "_inbox/Kafka Topic Partition.md"
@@ -195,10 +199,6 @@
     {
       "basename": "Обои на стене",
       "path": "_inbox/Обои на стене.md"
-    },
-    {
-      "basename": "Ремонт потолка",
-      "path": "_inbox/Ремонт потолка.md"
     }
   ],
   "omittedPaths": [],

_inbox/00 Kafka.md

@@ -60,7 +60,7 @@ Apache Kafka – это платформа потоковой передачи,
 Терминология:
 - Record - запись состоящая из ключа и значения
 - [Topic](Kafka%20Topic.md) - имя потока, куда публикуются Record
-- Offset - позиция записи
+- [Offset](Kafka%20Offset.md) - позиция записи
 - Pratition - шард топика
 
 

_inbox/Kafka Offset.md

@@ -0,0 +1,17 @@
+---
+aliases:
+  - offset
+tags:
+  - зрелость/🌱
+date:
+  - - 2024-08-26
+zero-link:
+  - "[[00 Kafka]]"
+parents: 
+linked:
+---
+- Брокер не отслеживает чтение потребителями
+- Потребители могут использовать Kafka для сохранения позиции смещения
+- Фиксация (commit) - действие по обновлению текущей позиции потребителя.
+- Потребители отправляют в специальную тему `__consumer_offsets` сообщение, содержащее смещение для каждого раздела
+- Аварийный сбой потребителя или присоединение нового потребителя инициирует ребалансировку.