@staticmethod
def build_dead_letter_publisher():
    return RequestsProcessorBuilder.build_producer(KAFKA_DEAD_LETTER_QUEUE_ACKS)
@staticmethod
def build_dead_letter_publisher():
    return RequestsProcessorBuilder.build_producer(KAFKA_DEAD_LETTER_QUEUE_ACKS)