diff --git a/.obsidian/plugins/home-tab/data.json b/.obsidian/plugins/home-tab/data.json index ab1190bf..0967a0d7 100644 --- a/.obsidian/plugins/home-tab/data.json +++ b/.obsidian/plugins/home-tab/data.json @@ -25,11 +25,11 @@ "recentFilesStore": [ { "filepath": "_inbox/Kafka Topic Partition.md", - "timestamp": 1724668068064 + "timestamp": 1724668117126 }, { "filepath": "_inbox/Consumer Group.md", - "timestamp": 1724668060321 + "timestamp": 1724668093407 }, { "filepath": "_inbox/Kafka Topic.md", diff --git a/_inbox/Consumer Group.md b/_inbox/Consumer Group.md index 49ce3893..f49ea29d 100644 --- a/_inbox/Consumer Group.md +++ b/_inbox/Consumer Group.md @@ -11,7 +11,7 @@ linked: --- Consumer Group позволяет распределить сообщения в топике между различными консьюмерами. Тем самым распределив нагрузку между репликами. -Этот механизм работает на базе партиций топика. В идеале создавать количество партиций равное количеству консьюмеров в группе. Если создать меньше, то часть консьюмеров будет простаивать не выполняя полезную работу, если создать больше, то некоторые консьюмеры возьмут на себя обработку сразу нескольких партиций, то есть нагрузка будет распространена не равномерно. +Этот механизм работает на базе [партиций](Kafka%20Topic%20Partition.md) топика. В идеале создавать количество партиций равное количеству консьюмеров в группе. ==Если создать меньше, то часть консьюмеров будет простаивать не выполняя полезную работу, если создать больше, то некоторые консьюмеры возьмут на себя обработку сразу нескольких партиций, то есть нагрузка будет распространена не равномерно.== Внутри консьюмер группы из одного Pratition может читать только один consumer. Но consumer может читать несколько Pratition одного и того же топика. Но можно создать несколько consumer group для одного и того же топика. diff --git a/_inbox/Kafka Topic Partition.md b/_inbox/Kafka Topic Partition.md index a7f22c4a..5dda6883 100644 --- a/_inbox/Kafka Topic Partition.md +++ b/_inbox/Kafka Topic Partition.md @@ -13,4 +13,11 @@ zero-link: parents: linked: --- -Разбиение на партиции позволяет реализовывать [Горизонтальное масштабирование](Горизонтальное%20масштабирование.md) с использованием [Consumer Group](Consumer%20Group.md). \ No newline at end of file +[Topic](Kafka%20Topic.md) можно разбить на Partitions. Partition может хранится на разных брокерах кластера. + +![500](Pasted%20image%2020240826133001.png) + +Сообщения могут записываться в разные партиции. +![](Pasted%20image%2020240826133128.png) + +Это позволяет реализовывать [Горизонтальное масштабирование](Горизонтальное%20масштабирование.md) с использованием [Consumer Group](Consumer%20Group.md). \ No newline at end of file diff --git a/meta/files/Pasted image 20240826133001.png b/meta/files/Pasted image 20240826133001.png new file mode 100644 index 00000000..cea051fd Binary files /dev/null and b/meta/files/Pasted image 20240826133001.png differ diff --git a/meta/files/Pasted image 20240826133128.png b/meta/files/Pasted image 20240826133128.png new file mode 100644 index 00000000..c84d4b65 Binary files /dev/null and b/meta/files/Pasted image 20240826133128.png differ