diff --git a/.obsidian/plugins/home-tab/data.json b/.obsidian/plugins/home-tab/data.json index 289f9a4a..d464b056 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/00 Kafka.md", + "timestamp": 1724152033556 + }, { "filepath": "_inbox/Kafka Connect.md", "timestamp": 1724152002564 @@ -31,10 +35,6 @@ "filepath": "knowledge/dev/java/other/JDBC.md", "timestamp": 1724151998864 }, - { - "filepath": "_inbox/00 Kafka.md", - "timestamp": 1724151928517 - }, { "filepath": "_inbox/Флаги очередей в RabbitMQ.md", "timestamp": 1724151453166 diff --git a/.obsidian/plugins/recent-files-obsidian/data.json b/.obsidian/plugins/recent-files-obsidian/data.json index e6f7dad4..f05f81c3 100644 --- a/.obsidian/plugins/recent-files-obsidian/data.json +++ b/.obsidian/plugins/recent-files-obsidian/data.json @@ -1,5 +1,9 @@ { "recentFiles": [ + { + "basename": "00 Kafka", + "path": "_inbox/00 Kafka.md" + }, { "basename": "Kafka Connect", "path": "_inbox/Kafka Connect.md" @@ -8,10 +12,6 @@ "basename": "JDBC", "path": "knowledge/dev/java/other/JDBC.md" }, - { - "basename": "00 Kafka", - "path": "_inbox/00 Kafka.md" - }, { "basename": "Флаги очередей в RabbitMQ", "path": "_inbox/Флаги очередей в RabbitMQ.md" diff --git a/_inbox/00 Kafka.md b/_inbox/00 Kafka.md index dc7b9a3b..fd9350d7 100644 --- a/_inbox/00 Kafka.md +++ b/_inbox/00 Kafka.md @@ -54,7 +54,7 @@ Apache Kafka – это платформа потоковой передачи, Помимо различных семантик доставки, есть еще одно общее преимущество использования брокера сообщений – если приложение потребитель потерпело аварию или остановлено для технического обслуживания, то производитель может не ждать, пока его сообщение будет обработано. Когда потребители возобновят работу и вернутся в сеть, они смогут продолжить с того места, на котором остановились, и обработать ожидающие сообщения. -Платформа Kafka изначально была ориентирована на работу с несколькими потребителями. Это означает, что приложение, читающее сообщение из брокера сообщений, не делает это сообщение недоступным для других приложений, которые также могут захотеть его получить и использовать. +Платформа Kafka изначально была ориентирована на работу с несколькими потребителями, - модель Publish & Subscribe. Это означает, что приложение, читающее сообщение из брокера сообщений, не делает это сообщение недоступным для других приложений, которые также могут захотеть его получить и использовать. Consumer сам следит за смещением offset, то есть он сам следит за тем, какие сообщения он уже прочитал. Сообщение, также называемое записью, является основной частью данных, проходящих через Kafka. Сообщения – это представление ваших данных в Kafka. Каждое сообщение имеет отметку времени, значение и необязательный ключ. При желании также можно добавлять свои заголовки @@ -63,6 +63,10 @@ Apache Kafka – это платформа потоковой передачи, ## Заметки - Реализована на Java - Не использует RAM для доступа к данным. +- Зачем нужен Zookeper + - Чтобы определить какая из нод лидер для конкретного топика + - Какое положение курсоров + - Где находятся партишены - Отправленные сообщения не удаляются после прочтения. - Позволяет повторно считать данные с любого места. Например, мы выполняли какую-то бухгалтерскую логику и поняли, что в приложении была допущена ошибка в формуле расчета. Мы можем удалить невалидные данные, поправить формулу и заново считать все старые сообщения. - Можно настроить ротацию, чтобы старые сообщения удалялись.