Я пытаюсь выставить конечную точку привода Spring Boot для моей конфигурации привязки. Мое приложение довольно простое, только с парой привязок KStream. Он написан функционально без каких-либо «обязательных» аннотаций, таких как @EnableBinding
или @StreamListener
. Он работает и работает, и когда я получаю доступ к / привод / привязки , происходит сбой со следующим исключением: Binding implementation `org.springframework.cloud.stream.binder.DefaultBinding` must implement this operation before it is called (through reference chain: java.util.ArrayList[0]->org.springframework.cloud.stream.binder.DefaultBinding["input"])
У меня вопрос, что является причиной для выброса UnsupportedOperationException
из метода org.springframework.cloud.stream.binder.Binding#isInput()
и не переопределить его в DefaultBinding, который используется для KStream? Или, может быть, DefaultBinding
- абсолютно неправильный компонент для привязки KStream?
Спасибо.