code: def _encoded_routing_key(self):
          
          topic = self.topic
          if config.conf["topic_prefix"]:
              topic = ".".join((config.conf["topic_prefix"].rstrip("."), topic))
          return topic.encode("utf-8")
docs: The encoded routing key used to publish the message on the broker.