數據流管道和pubsub模擬器

Question

我正在嘗試設置我的開發環境。我沒有在生產環境中使用Google雲端pubsub，而是使用pubsub模擬器進行開發和測試。爲了實現這一點，我設置以下的環境變量：

export PUBSUB_EMULATOR_HOST=localhost:8586 

這個工作對蟒谷歌發佈訂閱庫，但是當我切換到使用Java的Apache束的谷歌數據流，管道仍指向生產谷歌發佈訂閱。是否有需要設置的管道上的設置，環境變量或方法，以便管道讀取本地pubsub模擬器？

Answer 1

我在PubsubOptions接口中找到了解決方案，並將其擴展爲我自己的PipelineOptions實現。然後使用setPubsubRootUrl（）將其設置爲模擬器的localhost：port。