diff --git a/.obsidian/plugins/home-tab/data.json b/.obsidian/plugins/home-tab/data.json index 0967a0d7..79b1531b 100644 --- a/.obsidian/plugins/home-tab/data.json +++ b/.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": [], diff --git a/.obsidian/plugins/recent-files-obsidian/data.json b/.obsidian/plugins/recent-files-obsidian/data.json index 76abec5a..49728fe0 100644 --- a/.obsidian/plugins/recent-files-obsidian/data.json +++ b/.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": [], diff --git a/_inbox/00 Kafka.md b/_inbox/00 Kafka.md index 43ff1e91..3c3e2932 100644 --- a/_inbox/00 Kafka.md +++ b/_inbox/00 Kafka.md @@ -60,7 +60,7 @@ Apache Kafka – это платформа потоковой передачи, Терминология: - Record - запись состоящая из ключа и значения - [Topic](Kafka%20Topic.md) - имя потока, куда публикуются Record -- Offset - позиция записи +- [Offset](Kafka%20Offset.md) - позиция записи - Pratition - шард топика diff --git a/_inbox/Kafka Offset.md b/_inbox/Kafka Offset.md new file mode 100644 index 00000000..432bd3d0 --- /dev/null +++ b/_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` сообщение, содержащее смещение для каждого раздела +- Аварийный сбой потребителя или присоединение нового потребителя инициирует ребалансировку. \ No newline at end of file