Implemented GCP PubSub Consumer data integration bridge.