我有一个带有kafka绑定的spring-cloud-stream应用程序。我想从同一个可执行文件(Jar)中发送和接收来自同一个主题的消息。我有如下所示的频道定义:- public interface ChannelDefinition { @Input("forum") public SubscriableChannel readMessage(); @Output("forum") public MessageChannel postMessage(); }
我使用@StreamListener接收消息。我遇到了各种各样意想不到的