available or not
// 2.if it is up and running then process the message else put message into dead-letter// and after some interval when customer ai is available process dead-letter messages
static final TupleTag<TableRow> TRANSFORM_OUT = new TupleTag<TableRow>() {};
new TupleTag<FailsafeElement<PubsubMessage, String>>() {};
/** The tag for the dead-lettergetUseSubscriptio
configurer.configure(factory, consumerFactory); // Send all failed message from topic XYZ to another dead-letterorg.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] o.s.kafka.listener.DeadLetterPublishingRecoverer : Dead-letter