Я испытываю странное поведение, используя агрегаты и магазины.Когда я запускаю интеграционный тест, я отправляю сообщение 20, 21 и 22 января.Поскольку у меня есть агрегация с хранилищем окон за 1 день, я ожидаю иметь 3 окна, в которых каждое окно содержит сообщение.результат, однако, отличается.Я получаю только 2 окна, где первое окно содержит сообщение для 21-го, а второе - для 22-го.Так что сообщение для 20-го потеряно.Если повторить мой тест и отправить только 20-е и 21-е, я получу каждое сообщение в отдельном окне.
Затем я попробовал другой тест, где сообщения отправляются на 20-е, 21-е, 22-е и 23-е.Я ожидаю 4 окна.Тем не менее, я получаю два окна, но на этот раз первое окно содержит сообщение для 22-го, а второе окно содержит сообщение для 23-го.
Я включил ведение журнала трассировки, но не смог найти никаких проблем.У вас есть идея, что здесь происходит не так?Я бью баг?мой код включен https://github.com/mmelsen/spring-cloud-stream-binder-kafka. Запуск модульного теста показывает это поведение