I’m trying to check is my kafka listener fails to connect to kafka i need to make a rest call or any other action, but the problem is the kafka listener keeps trying to reconnect and it will never end, any suggestion? below what I have achieved so far but now working.

fun fallback(

    @Payload msg: obj,
    throwable: Throwable
) {
    if (throwable is DisconnectException) {
        logger.error { "Kafka DisconnectException: ${throwable.message}" }
    } else {
        logger.error { "Error in KafkaListenerService: $msg, Exception: ${throwable.message}" }
    }
}

@EventListener
fun listen(event: ListenerContainerIdleEvent) {
    println(event)
    try {
        logger.info("ListenerContainerIdleEvent: ${event.source}")
        logger.info("ListenerContainerIdleEvent: ${event.consumer.assignment()}")
        println("ERR::::::::::::::::"+event.consumer.assignment())
        println(event.consumer.endOffsets(event.consumer.assignment(), Duration.ofSeconds(5)))
    } catch (e: Exception) {
        e.printStackTrace()
    }
}