в кафке. Как я понял, есть два способа:
1. Установка max.in.flight.per.connections = 1, что не позволит отправлять несколько сообщений без подтверждения ответа, но уменьшит пропускную способность
2. Установка
enable.idempotence = true
max.in.flight.per.connection < 5
retries > 0
acks = all
Второй случай мне непонятен, ведь у нас может быть в флай состоянии больше 1 сообщения и если первое не пройдет, то порядок нарушится.
Может кто подскажет куда смотреть, что почитать?
кафка не синхронная очередь, и даже пытаться делать из неё синхронную очередь глупость если вам нужна синхронная очередь смотрите rabbit/nats либо если ук вас более лярда сообщений в час, отказывайтесь от ожидания что всё будет синхронно
Я понимаю, но вопрос про другое)
Обсуждают сегодня