vault backup: 2024-07-04 12:45:41
This commit is contained in:
parent
aad30b44c3
commit
7cb5856351
2
.obsidian/graph.json
vendored
2
.obsidian/graph.json
vendored
@ -46,6 +46,6 @@
|
|||||||
"repelStrength": 10,
|
"repelStrength": 10,
|
||||||
"linkStrength": 1,
|
"linkStrength": 1,
|
||||||
"linkDistance": 250,
|
"linkDistance": 250,
|
||||||
"scale": 0.26588896145134355,
|
"scale": 0.27876887851347015,
|
||||||
"close": false
|
"close": false
|
||||||
}
|
}
|
8
.obsidian/plugins/home-tab/data.json
vendored
8
.obsidian/plugins/home-tab/data.json
vendored
@ -24,12 +24,12 @@
|
|||||||
"unresolvedLinks": false,
|
"unresolvedLinks": false,
|
||||||
"recentFilesStore": [
|
"recentFilesStore": [
|
||||||
{
|
{
|
||||||
"filepath": "_inbox/Consumer Group.md",
|
"filepath": "_inbox/00 Kafka.md",
|
||||||
"timestamp": 1720085956278
|
"timestamp": 1720086242174
|
||||||
},
|
},
|
||||||
{
|
{
|
||||||
"filepath": "_inbox/00 Kafka.md",
|
"filepath": "_inbox/Consumer Group.md",
|
||||||
"timestamp": 1720085948146
|
"timestamp": 1720085956278
|
||||||
},
|
},
|
||||||
{
|
{
|
||||||
"filepath": "_inbox/00 RabbitMQ.md",
|
"filepath": "_inbox/00 RabbitMQ.md",
|
||||||
|
@ -1,13 +1,13 @@
|
|||||||
{
|
{
|
||||||
"recentFiles": [
|
"recentFiles": [
|
||||||
{
|
|
||||||
"basename": "Consumer Group",
|
|
||||||
"path": "_inbox/Consumer Group.md"
|
|
||||||
},
|
|
||||||
{
|
{
|
||||||
"basename": "00 Kafka",
|
"basename": "00 Kafka",
|
||||||
"path": "_inbox/00 Kafka.md"
|
"path": "_inbox/00 Kafka.md"
|
||||||
},
|
},
|
||||||
|
{
|
||||||
|
"basename": "Consumer Group",
|
||||||
|
"path": "_inbox/Consumer Group.md"
|
||||||
|
},
|
||||||
{
|
{
|
||||||
"basename": "00 RabbitMQ",
|
"basename": "00 RabbitMQ",
|
||||||
"path": "_inbox/00 RabbitMQ.md"
|
"path": "_inbox/00 RabbitMQ.md"
|
||||||
|
@ -13,7 +13,7 @@ Consumer Group позволяет распределить сообщения в
|
|||||||
|
|
||||||
Этот механизм работает на базе партиций топика. В идеале создавать количество партиций равное количеству консьюмеров в группе. Если создать меньше, то часть консьюмеров будет простаивать не выполняя полезную работу, если создать больше, то некоторые консьюмеры возьмут на себя обработку сразу нескольких партиций, то есть нагрузка будет распространена не равномерно.
|
Этот механизм работает на базе партиций топика. В идеале создавать количество партиций равное количеству консьюмеров в группе. Если создать меньше, то часть консьюмеров будет простаивать не выполняя полезную работу, если создать больше, то некоторые консьюмеры возьмут на себя обработку сразу нескольких партиций, то есть нагрузка будет распространена не равномерно.
|
||||||
|
|
||||||
Внутри консьюмер группы из одного Pratition может читать только один consumer. Но consumer может читать несколько Pratition одного и того же топика.
|
Внутри консьюмер группы из одного Pratition может читать только один consumer. Но consumer может читать несколько Pratition одного и того же топика. Но можно создать несколько consumer group для одного и того же топика.
|
||||||
|
|
||||||
Consumer Group автоматически перестраивается при изменении количества консьюмеов.
|
Consumer Group автоматически перестраивается при изменении количества консьюмеов.
|
||||||
![](Pasted%20image%2020240704123320.png)
|
![](Pasted%20image%2020240704123320.png)
|
Loading…
Reference in New Issue
Block a user