docs: def decompress_messages(self, partitions_offmsgs):
          """ Decompress pre-defined compressed fields for each message. """
  
          for pomsg in partitions_offmsgs:
              if pomsg['message']:
                  pomsg['message'] = self.decompress_fun(pomsg['message'])
              yield pomsg