как смоделировать KStream в весеннем облачном потоке для юнит-тестирования

Question

Как я могу написать модульный тест для метода ниже:

 public KStream<String, Object> process(KStream<String, Object> kstream) {
        return kstream
            .filter((key, value) -> isFilterRequired(value))
            .mapValues(this::mapValues);

Я использую среду Spring Cloud Stream, как я могу издеваться над KStream для вызова метода процесса или как я могу протестировать этот кусоккода в мире Spring Kafka.

Answer 1

Создайте метод, который возвращает топологию Kafka Streams, и тогда вы сможете протестировать его с помощью TopologyTestDriver.Не нужно насмехаться