В настоящее время нет поддержки источника PubSub в структурированной потоковой передаче Spark.
Кто-нибудь написал собственный источник в структурированной потоковой передаче Spark для чтения из PubSub?
Это возможный подход?