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

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

<
От версии < 29.4 >
отредактировано Alexandr Fokin
на 2022/06/27 15:49
К версии < 29.5 >
отредактировано Alexandr Fokin
на 2022/06/27 15:54
>
Изменить комментарий: Редактировать комментарий

Комментарий

Подробности

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