Any previous subscription will be unassigned and unsubscribed first.
The subscription set denotes the desired topics to consume and this
set is provided to the partition assignor (one of the elected group
members) for all clients which then uses the configured
\c partition.assignment.strategy to assign the subscription sets's
topics's partitions to the consumers, depending on their subscription.
The result of such an assignment is a rebalancing which is either
handled automatically in librdkafka or can be overriden by the application
by providing a RebalanceCb.
The rebalancing passes the assigned partition set to
assign() to update what partitions are actually
being fetched by the KafkaConsumer.
Regex pattern matching automatically performed for topics prefixed
with \c \"^\" (e.g. \c \"^myPfx[0-9]_.*\"
Update the subscription set to \p topics.
Any previous subscription will be unassigned and unsubscribed first.
The subscription set denotes the desired topics to consume and this set is provided to the partition assignor (one of the elected group members) for all clients which then uses the configured \c partition.assignment.strategy to assign the subscription sets's topics's partitions to the consumers, depending on their subscription.
The result of such an assignment is a rebalancing which is either handled automatically in librdkafka or can be overriden by the application by providing a RebalanceCb.
The rebalancing passes the assigned partition set to assign() to update what partitions are actually being fetched by the KafkaConsumer.
Regex pattern matching automatically performed for topics prefixed with \c \"^\" (e.g. \c \"^myPfx[0-9]_.*\"