有没有一种方法可以在Apache Beam作业中使用同步拉取来消费谷歌PubSub消息

import org.apache.beam.sdk.Pipeline;
import org.apache.beam.sdk.io.gcp.pubsub.PubsubIO;
import org.apache.beam.sdk.options.PipelineOptions;
import org.apache.beam.sdk.options.PipelineOptionsFactory;

public class PubsubExample {
  public static void main(String[] args) {
    // 创建PipelineOptions
    PipelineOptions options = PipelineOptionsFactory.create();

    // 创建Pipeline
    Pipeline pipeline = Pipeline.create(options);

    // 配置PubSub源
    pipeline.apply(
        "ReadFromPubSub",
        PubsubIO.readStrings().fromSubscription("projects/<project-id>/subscriptions/<subscription-id>"))
        // 应用其他转换操作
        .apply("ProcessData", ... )
        // 写入结果
        .apply(
        "WriteToPubSub",
        PubsubIO.writeStrings().to("projects/<project-id>/topics/<topic-id>"));

    // 运行流水线
    pipeline.run();
  }
}