def METHOD_NAME(self):
    cluster_name = kafka_config.get_topic_definition(self.topic)["cluster"]
    conf = {
        "bootstrap.servers": settings.KAFKA_CLUSTERS[cluster_name]["common"][
            "bootstrap.servers"
        ],
        "session.timeout.ms": 6000,
    }
    return Producer(conf)