code: def unack_all(self):
      self._get_or_create_consumer()
      self._consumer_receive.seek(pulsar.MessageId.earliest)
  
file_path: FATE/python/fate/arch/federation/backends/pulsar/_mq_channel.py
imports: import logging
  import pulsar
  from fate.arch.federation.message_queue import nretry
label_desc: Use image node_id 5 for calling the MQChannel obj's underlying member method code with example usage: obj.unack_all() without return types