работал@KafkaListener это также отмеченоConsumerAwareRebalanceListener интерфейс, используя Spring Boot 2.0.6. Я реализовалonPartitionsAssigned метод, в котором я перематываю смещение на фиксированное количество времени, скажем, 60 секунд.

Все идет нормально.

Как я могу протестировать приведенный выше вариант использования, используя инструменты, которые предоставляет мне Spring Kafka? Я предполагал, что мне нужно запустить брокера Kafka (т.е.EmbeddedKafka), затем остановив прослушиватель, а затем снова перезагрузите его, чтобы проверить, что он снова считывает сообщения, полученные за последние 60 секунд.

Кто-нибудь может мне помочь? Я немного погуглил, но ничего не нашел. Большое спасибо.