vault backup: 2024-08-20 14:12:08

.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

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

_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
+	- Чтобы определить какая из нод лидер для конкретного топика
+	- Какое положение курсоров
+	- Где находятся партишены
 - Отправленные сообщения не удаляются после прочтения. 
 	- Позволяет повторно считать данные с любого места. Например, мы выполняли какую-то бухгалтерскую логику и поняли, что в приложении была допущена ошибка в формуле расчета. Мы можем удалить невалидные данные, поправить формулу и заново считать все старые сообщения.
 	- Можно настроить ротацию, чтобы старые сообщения удалялись.