@StreamListener + Reactive + несколько тем на кафке не работают

Question

Я настроил одну тему на Kafka, затем с помощью загрузочного облака Spring, реактивного потока kafka, я получаю сообщение из темы

@StreamListener(value="video_encoding")
      public void handle( ConsumerRecord<String, String> message) {
       System.out.println(message.topic());
    }

результат

{"id":12,"message":"https://www.test.fr"}

это работает хорошо, но когда я просто добавляю новую тему на сервер kafka, так что теперь у меня есть 2 темы, этот слушатель больше не работает.

когда я пытаюсь таким образом

@StreamListener
public void log(@Input(Sink.INPUT) Flux<String> strings)
{
    strings.log().subscribe();
}

У меня есть эта ошибка

Caused by: java.lang.IllegalStateException: A default binder has been 
requested, but there is more than one binder available for 
'org.springframework.integration.channel.DirectChannel' : , and no default 
binder has been set.

есть идеи? я хотел бы использовать реактивный к и десериализации JSON