Заставить потребителя читать только те сообщения, которые пришли в тему после того, как потребитель ожил - PullRequest
1 голос
/ 19 марта 2019

Есть ли способ заставить потребителя прочитать последнюю версию?Например, допустим, у меня есть одна тема t1 и потребитель C1 в группе потребителей CG1.Если в t1 есть 10 сообщений (от m0 до m10), то, как только C1 приходит в себя, он читает первые 5 сообщений, а затем вылетает, а теперь, перед тем как вылететь, допустим, что он совершил offest до 5. Тем временем, тема получила еще 5 сообщений(от m11 до m15).Теперь C1 возвращается, и после этого t1 получает еще 5 сообщений (от m16 до m20).Я хочу, чтобы C1 принудительно начал чтение с m16 и т. Д., То есть из сообщения, которое t1 получил после того, как C1 вернулся.Из-за зафиксированного смещения он начнет читать с m6 и далее.Я в порядке с C1, чтобы потерять сообщение, когда оно было недоступно.Есть ли способ настроить моего потребителя для этого варианта использования.

1 Ответ

1 голос
/ 19 марта 2019

Настройка enable.auto.commit = false и auto.offset.reset = latest на моем потребителе работает для этого варианта использования.

...