Я бродил по Интернету для некоторых объяснений, и, поскольку я новичок в этом, я могу быть сбит с толку.
поэтому, когда мы хотим установить архитектуру микросервисов, нам понадобится наш микросервис для асинхронной связии что это делается с помощью kafka (в моем случае)
я следовал руководству, использующему Spring Cloud Stream , чтобы подключиться к работающему kafka и сделать его микросервис способным записывать сообщения взаданную тему и читать из заданной темы также.
так что я хотел бы знать, должен ли каждый из моих микросервисов интегрировать этот механизм?или у меня должен быть один микросервис, который объединяет весенний облачный поток, и когда нам нужно что-то из кафки, свяжитесь с ним?(что мне кажется нелогичным)
Я спрашиваю об этом, потому что я использую консула для обнаружения сервисов, и когда я интегрировал поток весеннего облака в проект, я получил эту ошибку:
Не удалось запустить bean-компонент 'outputBindingLifecycle';вложенное исключение - java.lang.IllegalStateException: было запрошено связывание по умолчанию, но для 'org.springframework.cloud.stream.messaging.DirectWithAttributesChannel' доступно несколько связывателей: consul, kafka, и связыватель по умолчанию не установлен.