我已经在网上漫游了一些解释，因为我是新来的，我可能会感到困惑。
因此，当我们想要设置一个微服务体系结构时，我们将需要我们的微服务来异步通信，这是通过kafka完成的（在我的例子中）
我遵循了一个使用springcloudstream的教程，以便与一个正在运行的kafka连接，并使他的microservice能够将msg写入一个给定的主题，并从一个给定的主题中读取。
所以我想知道的是，我的每一个微服务是否都应该整合这种机械主义？或者我应该有一个集成springcloudstream的微服务，当我们需要kafka的东西时，联系它(这对我来说似乎不合逻辑）
我问这个问题是因为我使用consul进行服务发现，当我在项目中集成spring cloud stream时，我遇到了以下错误：
未能启动bean'outputbindinglifecycle'；嵌套异常为java.lang.illegalstateexception:已请求默认绑定器，但“org.springframework.cloud.stream.messaging.directWithAttributeChannel”有多个绑定器可用：consur、kafka，未设置默认绑定器。