У меня та же проблема, что и у Github:
GoogleCloudPlatform / DataflowJavaSDK # 220
Если я пытаюсь запустить конвейер с помощью DirectRunner, предоставленного Apache Beam, и мне не принадлежит проект, содержащий тему, поток данных пытается создать подписку в том же проекте, что и тема, вместо проекта, на который есть ссылка в потоке данных. опции.
С уважением,