flink-connector-mongodb-cdc/src/main/java/com/ververica/cdc/connectors/mongodb/MongoDBSource.java
public Builder<T> pollMaxBatchSize(int pollMaxBatchSize) {
            checkArgument(pollMaxBatchSize > 0);
            this.pollMaxBatchSize = pollMaxBatchSize;
            return this;
        }
/**
         * poll.max.batch.size
         *
         * <p>Maximum number of change stream documents to include in a single batch when polling
         * for new data. This setting can be used to limit the amount of data buffered internally in
         * the connector. Default: 1000
         */
poll.max.batch.size
Maximum number of change stream documents to include in a single batch when polling
for new data. This setting can be used to limit the amount of data buffered internally in
the connector.
poll . max . batch . size Maximum number of change stream documents to include in a single batch when polling for new data . This setting can be used to limit the amount of data buffered internally in the connector .
public Builder<T> pollMaxBatchSize(int pollMaxBatchSize) {
            checkArgument(pollMaxBatchSize > 0);
            this.pollMaxBatchSize = pollMaxBatchSize;
            return this;
        }
public Builder < T > pollMaxBatchSize ( int pollMaxBatchSize ) { checkArgument ( pollMaxBatchSize > 0 ) ; this . pollMaxBatchSize = pollMaxBatchSize ; return this ; }
poll.max.batch.size
 <p>Maximum number of change stream documents to include in a single batch when polling
 for new data.
poll . max . batch . size <p > Maximum number of change stream documents to include in a single batch when polling for new data .