'Get metadata about the partitions for a given topic.
Arguments:
topic (str): Topic to check.
Returns:
set: Partition ids'

def partitions_for_topic(self, topic):

    return self._client.cluster.partitions_for_topic(topic)
