Kafka Stream подавляет агрегацию оконных сессий
Эта ошибка может быть вызвана неконтролируемыми требованиями к Java-версии.
В моем случае я смог разрешить эту ошибку, создав высокопрофильный проект с открытым исходным кодом, переключившись с Java 9 на Java 8 используя SDKMAN! .
sdk list java
sdk install java 8u152-zulu
sdk use java 8u152-zulu
Затем выполните чистую установку, как описано ниже.
При использовании Maven в качестве инструмента построения иногда полезно - и, как правило, приятно, сделать clean сборку установки с отключенным тестированием.
mvn clean install -DskipTests
Теперь, когда все построенный и установленный, вы можете продолжить и запустить тесты.
mvn test
1 ответ
Это ожидаемое поведение. Обратите внимание, что suppress() основано на времени события. Таким образом, до тех пор, пока новые данные не поступают, время не может продвигаться вперед, и, таким образом, удаление записи ранее будет неправильным, потому что нет никакой гарантии, что следующая запись может принадлежать текущему окну.