def simple_consumer(self, bp_ids_to_offsets):
        """bp_pairs_to_offsets is a dictionary of tuples to integers like the
        following:

        {
            "0-0" : 2038903,
            "0-1" : 3930198,
            "1-0" : 3932088,
            "1-1" : 958
        }

        The keys are of the format "[broker_id]-[partition_id]".

        The values are offsets.

        This method will return a SimpleConsumer that is initialied to read from
        the brokers listed at the offsets specified.
        """
        all_broker_partitions = self._zk_util.broker_partitions_for(self.topic)
        broker_partitions = dict((bp, bp_ids_to_offsets(bp.id))
                                 for bp in all_broker_partitions
                                 if bp.id in bp_ids_to_offsets)
        
        return SimpleConsumer(self.topic, broker_partitions)
dataset/ETHPy150Open DataDog/brod/brod/zk.py/ZKConsumer.simple_consumer/original