Подскажите а при manual commit можно ли сделать как нибудь

Question

pro.kafka

Alexander

Подскажите а при manual commit можно ли сделать как нибудь

чтобы не коммитились offset'ы которые меньше последнего закомитченного ?

#kafka #russian #software

0

08.02.2023

1 ответов

13 просмотров

George Bolshakov · Accepted Answer

нет. для каждого консьюмера просто пишется "последний закоммиченый" оффсет это, если перевести на человеческий, "номер последнего обработанного" и с кафка надо работать по принципу FIFO (first in first out) если вам надо параллелизм - используйте несколько партиций, для каждой партиции оффсет хранится отдельный (т.к. партиция де-факто отдельная очередь). тогда можете обрабатывать одновременно одно сообщение с одной партиции, но параллельно со всех партиций. P.S. как устроены топики и партиции https://developer.confluent.io/what-is-apache-kafka/#kafka-architecture--fundamental-concepts

52 похожих чатов

Подскажите а при manual commit можно ли сделать как нибудь

1 ответов

Похожие вопросы