Я пытаюсь проверить, не удается ли моему прослушивателю Kafka подключиться к Kafka. Мне нужно сделать вызов REST или любое другое действие, но проблема в том, что прослушиватель Kafka продолжает пытаться повторно подключиться, и это никогда не закончится. Есть ли у вас какие-либо предложения? Ниже показано, чего я достиг на данный момент, но не работает.
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()
}
}
Подробнее здесь: https://stackoverflow.com/questions/790 ... r-failover
