Изменения документа Гарантии доставки

Сводка

• Свойства страницы (1 изменено, 0 добавлено, 0 удалено)

Подробности

Свойства страницы

Содержимое

...	...	@@ -29,9 +29,13 @@
29	29	\\transactional.id - влияет на идентификацию экземпляра producer при переподключении. |(% style="width:1164px" %)Использование ручного коммита после завершения обработки (транзакции БД).
30	30	\\AutoOffsetReset = AutoOffsetReset.Earliest
31	31	ENABLE_AUTO_COMMIT = false
32		-\\Может использоваться для дедупликации.
	32	+\\Возможные проблемы:(((
	33	+1. Дублирование на отправке.
	34	+1. Не закомиченное смещение (падение consumer).
	35	+1. Отвал consumer по timeout (долгая обработка, сообщение передано к другому consumer).
	36	+
33	33	TransactionalInbox.
34		-\\Долгая обработка сообщения может привести к отключению consumer по timeout. Это может провести к тому, что сообщение поступит на другой потребитель. В таком случае только TransactionalInbox.
	38	+)))
35	35	|(% style="width:128px" %)(((
36	36	Exactly‑Once
37	37	)))|(% style="width:1164px" %)Гарантия доставки строго один раз.
...	...	@@ -42,7 +42,7 @@
42	42	|(% style="width:207px" %)Полный|(% style="width:991px" %)Хранится IdempotencyId каждого входящего сообщения (уникальный индекс), для дедубликации.
43	43	Полная защита от дублей (даже если это несколько сообщений, с одинаковым ключом).
44	44	|(% style="width:207px" %)Только offset (облегченный)|(% style="width:991px" %)Специфично для kafka. Храниться только topic+partition+offset.
45		-Защищает только от потери смещения (сообщение обработано, но offset не закомичен) и consumer timeout. Не было дублирование на отправке (более 1 сообщения).
	49	+Защищает только от потери смещения (сообщение обработано, но offset не закомичен) и consumer timeout. Не поможет при дублировании на отправке (более 1 сообщения).
46	46	|(% style="width:207px" %) |(% style="width:991px" %)
47	47	)))
48	48	|(% style="width:136px" %) |(% style="width:1216px" %)