Я пытаюсь проверить, не удается ли моему прослушивателю kafka подключиться к kafka. Мне нужно сделать вызов для отдыха или какое-либо другое действие, но проблема в том, что прослушиватель kafka продолжает пытаться повторно подключиться, и это никогда не закончится, какие-нибудь предложения? ниже того, чего я достиг до сих пор, но теперь работаю.
забавный запасной вариант(
@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
