public Builder<T> heartbeatIntervalMillis(int heartbeatIntervalMillis) {
            checkArgument(heartbeatIntervalMillis >= 0);
            this.heartbeatIntervalMillis = heartbeatIntervalMillis;
            return this;
        }
heartbeat.interval.ms

<p>The length of time in milliseconds between sending heartbeat messages. Heartbeat
messages contain the post batch resume token and are sent when no source records have
been published in the specified interval. This improves the resumability of the connector
for low volume namespaces. Use 0 to disable.
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/mongodb-cdc/src/main/java/org/apache/inlong/sort/cdc/mongodb/MongoDBSource.java