@Override
    public FlinkKafkaConsumerBase<T> setStartFromTimestamp(long startupOffsetsTimestamp) {
        // the purpose of this override is just to publicly expose the method for Kafka 0.10+;
        // the base class doesn't publicly expose it since not all Kafka versions support the functionality
        return super.setStartFromTimestamp(startupOffsetsTimestamp);
    }
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
kafka/kafka-source/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer.java