@Override
    protected boolean getIsAutoCommitEnabled() {
        return getBoolean(properties, ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, true)
                && PropertiesUtil.getLong(
                        properties, ConsumerConfig.AUTO_COMMIT_INTERVAL_MS_CONFIG, 5000) > 0;
    }
Creates a new Kafka streaming source consumer. Use this constructor to subscribe to multiple
topics based on a regular expression pattern.

<p>If partition discovery is enabled (by setting a non-negative value for {@link
FlinkKafkaConsumer#KEY_PARTITION_DISCOVERY_INTERVAL_MILLIS} in the properties), topics with
names matching the pattern will also be subscribed to as they are created on the fly.

<p>This constructor allows passing a {@see KafkaDeserializationSchema} for reading key/value
pairs, offsets, and topic names from Kafka.

@param subscriptionPattern The regular expression for a pattern of topic names to subscribe
        to.
@param deserializer The keyed de-/serializer used to convert between Kafka's byte messages
        and Flink's objects.
@param props
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/FlinkKafkaConsumer.java