@staticmethod
def build_error_publisher():
    return RequestsProcessorBuilder.build_producer(KAFKA_ERROR_ACKS)
@staticmethod
def build_error_publisher():
    return RequestsProcessorBuilder.build_producer(KAFKA_ERROR_ACKS)