code: def send(self, topic, *args, **kwargs):
          
          prefix_topic = self.heroku_kafka.prefix_topic(topic)
          return super(HerokuKafkaProducer, self).send(prefix_topic, *args, **kwargs)
docs: Appends the prefix to the topic before sendingf