во время обработки, например, сдох продюсер внезапно.
кафка запишет ту часть сообщений которая успела дойти? мне тут видится три варианта:
1) записывает часть сообщений котрые успели дойти и они остаются
2) записывает, но потом откатывает, т.к. суммарно произошла ошибка обработки сообщения
3) даже и не пишет, пытается сначала полностью вычитать сообщение в память и декодировать его целиком, и только потом начать писать на диск
собственно впорос, а что прсоиходит в кафке при таком сценрии?
Если включили транцакционность, то второй вариант, по идее. Но с транзакционностью я не работал, потому не знаю.
Батч не отправится в этом случае. Он же в буфере продьюсера сидит до отправки в сокет
Обсуждают сегодня