закрытия/открытия консьюмера. Когда консьюмер закрываю можно ли его обратно открыть? Или его только пересоздать можно?
А зачем ты его закрываешь-открываешь? Не похоже что его можно заново переоткрыть из реализации
ну я в доке увидел, что его закрывают. Погуглил что если не закрыть то с консистентностью данных могут быть проблемы. Ну мне кажется мб консьюмер сессион-скоуп сущность, ток я в этом не уверен. Не хотелось бы чтобы с данными что-то случилось просто потому что я не стал закрывать консьюмер
Когда ты закрываешь consumer, происходит коммит смещений. Соответсвенно если ты consumer не закроешь корректно, есть вероятность что при его завершении у тебя последние смещения не будут закоммичены.
Коммитить надо сразу после чтения? Или можно с этим повременить? Суть вопроса в том закрывать ли консьюмер когда приложение закрывается или надо закрывать после каждого чтения
По-умолчанию в KafkaConsumer включен автокоммитит, смещения записываются каждые 5 секунд.
Обсуждают сегодня