@staticmethod
def build_success_publisher():
    return RequestsProcessorBuilder.build_producer(KAFKA_SUCCESS_ACKS)
@staticmethod
def build_success_publisher():
    return RequestsProcessorBuilder.build_producer(KAFKA_SUCCESS_ACKS)