такую конфигурацию
bindings:
some-binding-name-in:
destination: ${topic.name}
consumer:
resetOffsets: true
startOffset: latest
со стороны кафки группа создается каждый раз новая при перегрузки микросервиса, что то вида "anonymous.b135f327-004a-4fc0-b0f5-99b72fce633b" и офсет консюмера всегда latest, то есть я не получаю уже когда либо закомиченые меседжи, вопрос как это работает ? Берет офсет последней с префиксом anonymous. ?
Если же сделать конфигураию с групой, которая генерится при перегрузке микросервиса каждый раз новая то startOffset: latest не работает по схеме как выше ну это и логично в принципе, мы приходим на кафку и спрашиваем офсет этой группы которой нет и читаем сначала в новой консюмер группе. Вопрос как сделать поведение анологично как с анонимной группой (просто юзать анонимную нельзя, есть требования именовать групу по имени консумера)? Может называть группу с префиксом правильным или это просто невозможно ?
bindings:
some-binding-name-in:
group: ${GROUP_NAME}
destination: ${topic.name}
consumer:
resetOffsets: true
startOffset: latest
а генерить группу нельзя при старте с включением имени консюмера как префикс?
Обсуждают сегодня