我正在尝试设置我的开发环境 . 我一直在使用pubsub模拟器进行开发和测试，而不是在 生产环境 中使用google cloud pubsub . 为此，我设置了以下环境变量：
export PUBSUB_EMULATOR_HOST=localhost:8586
这适用于python google pubsub库但是当我切换到使用java apache beam for google dataflow时，管道仍然指向 生产环境 google pubsub . 管道上是否有设置，环境变量或方法需要设置，以便管道读取本地pubsub模拟器？
1 回答
我在PubsubOptions接口中找到了解决方案，并将其扩展为我自己的PipelineOptions实现 . 然后使用setPubsubRootUrl（）将其设置为模拟器的localhost：port .