vault backup: 2024-07-02 19:38:27
This commit is contained in:
parent
135e8ea292
commit
1d1a4b6093
28
.obsidian/plugins/home-tab/data.json
vendored
28
.obsidian/plugins/home-tab/data.json
vendored
@ -23,25 +23,21 @@
|
|||||||
"markdownOnly": false,
|
"markdownOnly": false,
|
||||||
"unresolvedLinks": false,
|
"unresolvedLinks": false,
|
||||||
"recentFilesStore": [
|
"recentFilesStore": [
|
||||||
|
{
|
||||||
|
"filepath": "wiki/zero/00 Kafka.md",
|
||||||
|
"timestamp": 1719938290920
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"filepath": "_inbox/Брокер сообщений.md",
|
||||||
|
"timestamp": 1719938280292
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"filepath": "Home.md",
|
||||||
|
"timestamp": 1719938054255
|
||||||
|
},
|
||||||
{
|
{
|
||||||
"filepath": "_inbox/Индекс в PostgreSQL.md",
|
"filepath": "_inbox/Индекс в PostgreSQL.md",
|
||||||
"timestamp": 1719933867538
|
"timestamp": 1719933867538
|
||||||
},
|
|
||||||
{
|
|
||||||
"filepath": "_inbox/Индексы в MySQL.md",
|
|
||||||
"timestamp": 1719933854879
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"filepath": "_inbox/Транзакция БД.md",
|
|
||||||
"timestamp": 1719933704525
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"filepath": "_inbox/Serializable.md",
|
|
||||||
"timestamp": 1719933618607
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"filepath": "Проекты.md",
|
|
||||||
"timestamp": 1719933588467
|
|
||||||
}
|
}
|
||||||
],
|
],
|
||||||
"bookmarkedFileStore": [],
|
"bookmarkedFileStore": [],
|
||||||
|
@ -1,5 +1,17 @@
|
|||||||
{
|
{
|
||||||
"recentFiles": [
|
"recentFiles": [
|
||||||
|
{
|
||||||
|
"basename": "00 Kafka",
|
||||||
|
"path": "wiki/zero/00 Kafka.md"
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"basename": "Брокер сообщений",
|
||||||
|
"path": "_inbox/Брокер сообщений.md"
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"basename": "Home",
|
||||||
|
"path": "Home.md"
|
||||||
|
},
|
||||||
{
|
{
|
||||||
"basename": "Индекс в PostgreSQL",
|
"basename": "Индекс в PostgreSQL",
|
||||||
"path": "_inbox/Индекс в PostgreSQL.md"
|
"path": "_inbox/Индекс в PostgreSQL.md"
|
||||||
@ -28,10 +40,6 @@
|
|||||||
"basename": "Проект. Обучение Highload",
|
"basename": "Проект. Обучение Highload",
|
||||||
"path": "projects/Проект. Обучение Highload.md"
|
"path": "projects/Проект. Обучение Highload.md"
|
||||||
},
|
},
|
||||||
{
|
|
||||||
"basename": "Home",
|
|
||||||
"path": "Home.md"
|
|
||||||
},
|
|
||||||
{
|
{
|
||||||
"basename": "Read committed",
|
"basename": "Read committed",
|
||||||
"path": "_inbox/Read committed.md"
|
"path": "_inbox/Read committed.md"
|
||||||
@ -187,18 +195,6 @@
|
|||||||
{
|
{
|
||||||
"basename": "Досрочное погашение ипотеки",
|
"basename": "Досрочное погашение ипотеки",
|
||||||
"path": "projects/Ремонт квартиры/Досрочное погашение ипотеки.md"
|
"path": "projects/Ремонт квартиры/Досрочное погашение ипотеки.md"
|
||||||
},
|
|
||||||
{
|
|
||||||
"basename": "pg_stat_statements",
|
|
||||||
"path": "_inbox/pg_stat_statements.md"
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"basename": "Архитектура MySQL",
|
|
||||||
"path": "_inbox/Архитектура MySQL.md"
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"basename": "00 PostgreSQL",
|
|
||||||
"path": "wiki/zero/00 PostgreSQL.md"
|
|
||||||
}
|
}
|
||||||
],
|
],
|
||||||
"omittedPaths": [],
|
"omittedPaths": [],
|
||||||
|
@ -1,4 +1,15 @@
|
|||||||
Apache Kafka – это платформа потоковой передачи, которую можно использовать для быстрой обработки большого коли- чества событий.
|
---
|
||||||
|
aliases:
|
||||||
|
tags:
|
||||||
|
- зрелость/🌱
|
||||||
|
date:
|
||||||
|
- - 2024-07-02
|
||||||
|
zero-link:
|
||||||
|
- "[[00 Kafka]]"
|
||||||
|
parents: []
|
||||||
|
linked:
|
||||||
|
---
|
||||||
|
Apache Kafka – это платформа потоковой передачи, которую можно использовать для быстрой обработки большого количества событий.
|
||||||
|
|
||||||
Доставка сообщений в Kafka может осущест- вляться как минимум тремя способами:
|
Доставка сообщений в Kafka может осущест- вляться как минимум тремя способами:
|
||||||
- не менее одного раза (at-least-once) – сообщение будет отправля- ется потребителям до тех пор, пока те не подтвердят его полу- чение;
|
- не менее одного раза (at-least-once) – сообщение будет отправля- ется потребителям до тех пор, пока те не подтвердят его полу- чение;
|
12
_inbox/Брокер сообщений.md
Normal file
12
_inbox/Брокер сообщений.md
Normal file
@ -0,0 +1,12 @@
|
|||||||
|
---
|
||||||
|
aliases:
|
||||||
|
tags:
|
||||||
|
- зрелость/🌱
|
||||||
|
date:
|
||||||
|
- - 2024-07-02
|
||||||
|
zero-link:
|
||||||
|
- "[[00 Архитектура ПО]]"
|
||||||
|
parents:
|
||||||
|
linked:
|
||||||
|
---
|
||||||
|
- [Kafka](00%20Kafka.md)
|
34
wiki/zero/00 Kafka.md
Normal file
34
wiki/zero/00 Kafka.md
Normal file
@ -0,0 +1,34 @@
|
|||||||
|
---
|
||||||
|
aliases:
|
||||||
|
- кафка
|
||||||
|
- kafka
|
||||||
|
tags:
|
||||||
|
- type/zero-link
|
||||||
|
date:
|
||||||
|
- - 2024-07-02
|
||||||
|
- - 2024-07-02
|
||||||
|
zero-link:
|
||||||
|
- "[[00 Архитектура ПО]]"
|
||||||
|
linked:
|
||||||
|
---
|
||||||
|
Apache Kafka – это платформа потоковой передачи, которую можно использовать для быстрой обработки большого количества событий.
|
||||||
|
|
||||||
|
Доставка сообщений в Kafka может осуществляться как минимум тремя способами:
|
||||||
|
- не менее одного раза (at-least-once) – сообщение будет отправляется потребителям до тех пор, пока те не подтвердят его получение;
|
||||||
|
- не более одного раза (at-most-once) – сообщение отправляется только один раз и в случае сбоя не отправляется повторно;
|
||||||
|
- точно один раз (exactly-once) – потребитель гарантированно получит сообщение ровно один раз.
|
||||||
|
|
||||||
|
![](c85390a0-94b2-48f9-8dea-02d9bacc2562.jpg)
|
||||||
|
|
||||||
|
![](49356685-5474-490b-975a-d198d7f966bb.jpg)
|
||||||
|
|
||||||
|
![](3ad2bf28-e12a-4be7-9336-c38c7b5d7018.jpg)
|
||||||
|
|
||||||
|
Помимо различных семантик доставки, есть еще одно общее преимущество использования брокера сообщений – если приложение потребитель потерпело аварию или остановлено для тех- нического обслуживания, то производитель может не ждать, пока его сообщение будет обработано. Когда потребители возобновят работу и вернутся в сеть, они смогут продолжить с того места, на котором остановились, и обработать ожидающие сообщения.
|
||||||
|
|
||||||
|
Платформа Kafka изначально была ориентирована на работу с несколькими потребителями. Это означает, что приложение, чи- тающее сообщение из брокера сообщений, не делает это сообще- ние недоступным для других приложений, которые также могут за- хотеть его получить и использовать.
|
||||||
|
|
||||||
|
Сообщение, также называемое записью, является основной частью данных, проходящих через Kafka. Сообщения – это представле- ние ваших данных в Kafka. Каждое сообщение имеет отметку времени, значение и необязательный ключ. При желании также можно добавлять свои заголовки
|
||||||
|
|
||||||
|
![](ae8f6a39-5a3f-4195-8f6a-0b96e492413c.jpg)
|
||||||
|
|
Loading…
Reference in New Issue
Block a user