@staticmethod
def build_producer(acknowledgements):
    return KafkaProducer(bootstrap_servers=[KAFKA_BOOTSTRAP_SERVER], value_serializer=(lambda value: json.dumps(value).encode(KAFKA_VALUE_ENCODING)), acks=acknowledgements)
@staticmethod
def build_producer(acknowledgements):
    return KafkaProducer(bootstrap_servers=[KAFKA_BOOTSTRAP_SERVER], value_serializer=(lambda value: json.dumps(value).encode(KAFKA_VALUE_ENCODING)), acks=acknowledgements)