code: def beginning_offsets(self, partitions):
          
          offsets = self._fetcher.beginning_offsets(
              partitions, self.config['request_timeout_ms'])
          return offsets
docs: Get the first offset for the given partitions.
  
          This method does not change the current consumer position of the
          partitions.
  
          Note:
              This method may block indefinitely if the partition does not exist.
  
          Arguments:
              partitions (list): List of TopicPartition instances to fetch
                  offsets for.
  
          Returns:
              ``{TopicPartition: int}``: The earliest available offsets for the
              given partitions.
  
          Raises:
              UnsupportedVersionError: If the broker does not support looking
                  up the offsets by timestamp.
              KafkaTimeoutError: If fetch failed in request_timeout_ms.