Создал библиотеку, в которой есть один потребитель облачного потока и производитель облачного потока, и эта библиотека внедрена во все микросервисы в качестве зависимости, это отлично работает для меня.
У меня есть требование, чтобы некоторые микросервисы не нуждались в потребителе. Поэтому ищите гибкость для отключения/включения потребителя на основе некоторых настроенных свойств для использования одной и той же библиотеки.