Изменения документа Apache Kafka

Редактировал(а) Alexandr Fokin 2024/09/07 11:00

<
От версии < 29.7 >
отредактировано Alexandr Fokin
на 2022/10/28 15:25
К версии < 29.6 >
отредактировано Alexandr Fokin
на 2022/10/28 15:23
>
Изменить комментарий: К данной версии нет комментариев

Комментарий

Подробности

XWiki.XWikiComments[1]
Автор
... ... @@ -1,0 +1,1 @@
1 +XWiki.cccc1808
Комментарий
... ... @@ -1,0 +1,7 @@
1 +Если запросить группу сообщений и выполнить коммит последнего, то смещение установиться на позиции последнего элемента +1.
2 +Нет возможности закоммитить только определенное [i] сообщение.
3 +
4 +Некоторые другие брокеры устроены иначе: они работают с отдельными сообщениями и позволяют подтверждать их потребление независимо. В Kafke же единственным критерием является Offset.
5 +
6 +Опциально можно реализовать собственную логику работы с сообщениями, в том числе не возлагая на броке обязанности контролировать смещение, а управляя чтением самостоятельно.
7 +Обычно в Kafka не предполагается, что сообщение будет удалено сразу, и к нему можно обращаются по его значению Offset.
Дата
... ... @@ -1,0 +1,1 @@
1 +2020-02-17 18:44:48.607