Изменения документа Компоненты
Редактировал(а) Alexandr Fokin 2023/01/11 15:18
<
>
отредактировано Alexandr Fokin
на 2023/01/11 15:17
на 2023/01/11 15:17
отредактировано Alexandr Fokin
на 2022/10/28 15:25
на 2022/10/28 15:25
Изменить комментарий:
Добавлен комментарий
Комментарий
-
Свойства страницы (1 изменено, 0 добавлено, 0 удалено)
-
Объекты (0 изменено, 0 добавлено, 2 удалено)
Подробности
- Свойства страницы
-
- Содержимое
-
... ... @@ -3,8 +3,8 @@ 3 3 |(% style="width:180px" %)**Producer**|(% style="width:1302px" %)Клиент производитель сообщений 4 4 |(% style="width:180px" %)**Consumer**|(% style="width:1302px" %)Клиент потребитель сообщений 5 5 |(% style="width:180px" %) |(% style="width:1302px" %) 6 -|(% style="width:180px" %)**Topic**|(% style="width:1302px" %)Содержит внутри себя одну и более __Partition__. Кол-во __Partition__ определяет максимальную степень [[параллелизма>>doc:Разработка.NET.C#.Многопоточностьи асинхронность2.Параллелизм.WebHome]]при потреблении сообщений.7 -При отправке сообщение в топик, для него выбирается оди низ __Partition__, в который и размещается сообщение.6 +|(% style="width:180px" %)**Topic**|(% style="width:1302px" %)Содержит внутри себя одну и более __Partition__. Кол-во __Partition__ определяет максимальную степень параллелизма при потреблении сообщений. 7 +При отправке сообщение в топик, для него выбирается одиз из __Partition__, в который и размещается сообщение. 8 8 После потребления сообщения оно не удаляется сразу и некоторое время продолжает храниться и доступно для чтения (Определяется конфигурацией). 9 9 |(% style="width:180px" %)**Partition**|(% style="width:1302px" %)Представляет из себя очередь, содержащую последовательность экземпляров сообщений, при этом у каждого сообщения есть свой уникальный числовой порядковый номер. 10 10 Для каждого читаемого __Partition__ у потребителя храниться значение __Offset__ - смещение, порядковый номер текущего сообщения. После прочтения __Offset__ увеличивается на 1.
- XWiki.XWikiComments[2]
-
- Автор
-
... ... @@ -1,1 +1,0 @@ 1 -XWiki.cccc1808 - Комментарий
-
... ... @@ -1,8 +1,0 @@ 1 -Что такое гарантия доставки сообщений или как избавиться от дублей и потерь в Apache Kafka и других Big Data брокерах 2 -[[https:~~/~~/www.bigdataschool.ru/blog/kafka-exactly-once.html>>url:https://www.bigdataschool.ru/blog/kafka-exactly-once.html]] 3 - 4 -Как ускорить работу producer’ов Kafka: параметры конфигурации производителей 5 -[[https:~~/~~/www.bigdataschool.ru/blog/kafka-producers-configuration.html>>url:https://www.bigdataschool.ru/blog/kafka-producers-configuration.html]] 6 - 7 -Почему ваша Kafka такая медленная и как ее ускорить: 7 главных факторов производительности этой Big Data системы 8 -[[https:~~/~~/www.bigdataschool.ru/blog/kafka-performance-factors.html>>url:https://www.bigdataschool.ru/blog/kafka-performance-factors.html]] - Дата
-
... ... @@ -1,1 +1,0 @@ 1 -2022-10-28 11:25:47.850
- XWiki.XWikiComments[3]
-
- Автор
-
... ... @@ -1,1 +1,0 @@ 1 -XWiki.cccc1808 - Комментарий
-
... ... @@ -1,7 +1,0 @@ 1 -Изменение параметра максимального размера сообщения: 2 - 3 -Kafka - Broker: Message size too large 4 -[[https:~~/~~/stackoverflow.com/questions/59322133/kafka-broker-message-size-too-large>>url:https://stackoverflow.com/questions/59322133/kafka-broker-message-size-too-large]] 5 - 6 -Increase message.max.bytes 7 -[[https:~~/~~/github.com/bitnami/bitnami-docker-kafka/issues/13>>url:https://github.com/bitnami/bitnami-docker-kafka/issues/13]] - Дата
-
... ... @@ -1,1 +1,0 @@ 1 -2022-10-28 11:26:03.849