flink-connector-mongodb-cdc/src/main/java/com/ververica/cdc/connectors/mongodb/MongoDBSource.java
public Builder<T> pollAwaitTimeMillis(int pollAwaitTimeMillis) {
            checkArgument(pollAwaitTimeMillis > 0);
            this.pollAwaitTimeMillis = pollAwaitTimeMillis;
            return this;
        }
/**
         * poll.await.time.ms
         *
         * <p>The amount of time to wait before checking for new results on the change stream.
         * Default: 3000
         */
poll.await.time.ms
The amount of time to wait before checking for new results on the change stream.
poll . await . time . ms The amount of time to wait before checking for new results on the change stream .
public Builder<T> pollAwaitTimeMillis(int pollAwaitTimeMillis) {
            checkArgument(pollAwaitTimeMillis > 0);
            this.pollAwaitTimeMillis = pollAwaitTimeMillis;
            return this;
        }
public Builder < T > pollAwaitTimeMillis ( int pollAwaitTimeMillis ) { checkArgument ( pollAwaitTimeMillis > 0 ) ; this . pollAwaitTimeMillis = pollAwaitTimeMillis ; return this ; }
poll.await.time.ms
 <p>The amount of time to wait before checking for new results on the change stream.
poll . await . time . ms <p > The amount of time to wait before checking for new results on the change stream .