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