vault backup: 2024-08-20 14:02:07
This commit is contained in:
parent
b132f71df9
commit
169d120852
12
.obsidian/plugins/home-tab/data.json
vendored
12
.obsidian/plugins/home-tab/data.json
vendored
@ -23,6 +23,14 @@
|
|||||||
"markdownOnly": false,
|
"markdownOnly": false,
|
||||||
"unresolvedLinks": false,
|
"unresolvedLinks": false,
|
||||||
"recentFilesStore": [
|
"recentFilesStore": [
|
||||||
|
{
|
||||||
|
"filepath": "_inbox/00 Kafka.md",
|
||||||
|
"timestamp": 1724151458389
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"filepath": "_inbox/Флаги очередей в RabbitMQ.md",
|
||||||
|
"timestamp": 1724151453166
|
||||||
|
},
|
||||||
{
|
{
|
||||||
"filepath": "_inbox/00 RabbitMQ.md",
|
"filepath": "_inbox/00 RabbitMQ.md",
|
||||||
"timestamp": 1724151210046
|
"timestamp": 1724151210046
|
||||||
@ -31,10 +39,6 @@
|
|||||||
"filepath": "_inbox/Кластер RabbitMQ.md",
|
"filepath": "_inbox/Кластер RabbitMQ.md",
|
||||||
"timestamp": 1724151081888
|
"timestamp": 1724151081888
|
||||||
},
|
},
|
||||||
{
|
|
||||||
"filepath": "_inbox/Флаги очередей в RabbitMQ.md",
|
|
||||||
"timestamp": 1724148467882
|
|
||||||
},
|
|
||||||
{
|
{
|
||||||
"filepath": "Home.md",
|
"filepath": "Home.md",
|
||||||
"timestamp": 1724137322406
|
"timestamp": 1724137322406
|
||||||
|
@ -1,5 +1,13 @@
|
|||||||
{
|
{
|
||||||
"recentFiles": [
|
"recentFiles": [
|
||||||
|
{
|
||||||
|
"basename": "00 Kafka",
|
||||||
|
"path": "_inbox/00 Kafka.md"
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"basename": "Флаги очередей в RabbitMQ",
|
||||||
|
"path": "_inbox/Флаги очередей в RabbitMQ.md"
|
||||||
|
},
|
||||||
{
|
{
|
||||||
"basename": "00 RabbitMQ",
|
"basename": "00 RabbitMQ",
|
||||||
"path": "_inbox/00 RabbitMQ.md"
|
"path": "_inbox/00 RabbitMQ.md"
|
||||||
@ -8,10 +16,6 @@
|
|||||||
"basename": "Кластер RabbitMQ",
|
"basename": "Кластер RabbitMQ",
|
||||||
"path": "_inbox/Кластер RabbitMQ.md"
|
"path": "_inbox/Кластер RabbitMQ.md"
|
||||||
},
|
},
|
||||||
{
|
|
||||||
"basename": "Флаги очередей в RabbitMQ",
|
|
||||||
"path": "_inbox/Флаги очередей в RabbitMQ.md"
|
|
||||||
},
|
|
||||||
{
|
{
|
||||||
"basename": "Home",
|
"basename": "Home",
|
||||||
"path": "Home.md"
|
"path": "Home.md"
|
||||||
|
@ -11,7 +11,14 @@ zero-link:
|
|||||||
- "[[00 Архитектура ПО]]"
|
- "[[00 Архитектура ПО]]"
|
||||||
linked:
|
linked:
|
||||||
---
|
---
|
||||||
Apache Kafka – это платформа потоковой передачи, которую можно использовать для быстрой обработки большого количества событий. Строго говоря это не [Брокер сообщений](Брокер%20сообщений.md), а распределенный реплецированный журнал фиксаций изменений (commit log).
|
Apache Kafka – это платформа потоковой передачи, которую можно использовать для быстрой обработки большого количества событий. Строго говоря это не [Брокер сообщений](Брокер%20сообщений.md), а распределенный реплицированный журнал фиксаций изменений (commit log).
|
||||||
|
|
||||||
|
Где встречается потребности в потоковой обработке:
|
||||||
|
- Финансовые транзакции
|
||||||
|
- Действия в онлайн магазинах
|
||||||
|
- Перемещения пользователей
|
||||||
|
- Социальные сети
|
||||||
|
- Промышленные датчики
|
||||||
|
|
||||||
![](Pasted%20image%2020240703120512.png)
|
![](Pasted%20image%2020240703120512.png)
|
||||||
|
|
||||||
@ -33,7 +40,6 @@ Apache Kafka – это платформа потоковой передачи,
|
|||||||
- Offset - позиция записи
|
- Offset - позиция записи
|
||||||
- Pratition - шард топика
|
- Pratition - шард топика
|
||||||
|
|
||||||
|
|
||||||
Доставка сообщений в Kafka может осуществляться как минимум тремя способами:
|
Доставка сообщений в Kafka может осуществляться как минимум тремя способами:
|
||||||
- не менее одного раза (at-least-once) – сообщение будет отправляется потребителям до тех пор, пока те не подтвердят его получение;
|
- не менее одного раза (at-least-once) – сообщение будет отправляется потребителям до тех пор, пока те не подтвердят его получение;
|
||||||
- не более одного раза (at-most-once) – сообщение отправляется только один раз и в случае сбоя не отправляется повторно;
|
- не более одного раза (at-most-once) – сообщение отправляется только один раз и в случае сбоя не отправляется повторно;
|
||||||
|
Loading…
Reference in New Issue
Block a user