Пытаясь понять, фильтр не работает - PullRequest
Новая
       42

Пытаясь понять, фильтр не работает

0 голосов
/ 09 января 2020

Я немного озадачен, почему не работает фильтр ниже. Я получаю значение потока на входе topi c как «start». Есть идеи, почему это просто не работает? Я использую Spring Cloud stream 3.0, весеннюю загрузку 2.2.1.RELEASE на Java 11.

Фрагмент кода 

        public Function<KStream<String, String>, KStream<String, String>> filterstream() {
            return input -> input.map((key, value) -> new KeyValue<>(key, value))
                    .peek((key, value) -> System.out.println("......Key :" + key + "....Value: " + value))
                    .filter((key, value) -> value.equalsIgnoreCase("start"))
                    .peek((key, value) -> System.out.println(".after filter.....Key :" + key + "....Value: " + value));
       }

application.yml 

filterstream-in-0:
          destination: myinput
        filterstream-out-0:
          destination: filteredoutput
...