Я создал сервис SpringBoot, который использует SpringCloud @StreamListener для обработки сообщений kafka.
Предположим, у меня есть тема кафки, по которой уже опубликовано много сообщений.Мой потребитель @StreamListener может читать эти сообщения в потоке.
Давайте представим, что текущее смещение составляет, например, 300, и я вижу некоторую ошибку с сообщением 200. Я хотел бы обработать его.
Можно ли снова прочитать сообщение со смещением 200 и пропустить уже прочитанные сообщения с большим смещением?Или мне придется переигрывать также все сообщения с 201 по 300?