@Override
    public void subscribe(Collection<String> topics) {
        delegate.subscribe(topics);
    }
Subscribe to the given list of topics to get dynamically assigned partitions.
<b>Topic subscriptions are not incremental. This list will replace the current
assignment, if there is one.</b> If the given list of topics is empty, it is treated the same as {@link #unsubscribe()}.

<p>
As part of group management, the coordinator will keep track of the list of consumers that belong to a particular
group and will trigger a rebalance operation if any one of the following events are triggered:
<ul>
<li>A member joins or leaves the share group
<li>An existing member of the share group is shut down or fails
<li>The number of partitions changes for any of the subscribed topics
<li>A subscribed topic is created or deleted
</ul>

@param topics The list of topics to subscribe to

@throws IllegalArgumentException if topics is null or contains null or empty elements
@throws KafkaException for any other unrecoverable errors
clients/src/main/java/org/apache/kafka/clients/consumer/KafkaShareConsumer.java