Привет, кто-нибудь знает, как со стандартным java api поймать кейс,

Question

Привет, кто-нибудь знает, как со стандартным java api поймать кейс,

когда брокер недоступен? В таком случае на poll() возвращается пустая коллекция рекордов и в лог пишется ворнинг. Но пустая коллекция возможна и когда нет новых сообщений, как отличить эти два кейса?

#kafka #russian #software

0

27.11.2020

5 ответов

16 просмотров

Andrey Belyakov Автор вопроса

Юра Ходырев
А при вызове метода пол никакие таймеры на таймаут...

Там API по умолчанию принимает duration: https://kafka.apache.org/26/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#poll-java.time.Duration- но, когда ответ получен, я не знаю как отличить кейс с недоступным брокером, от кейса с пустым ответом. В списке исключений нет ничего похожего, да он его и не бросает, я бы сразу это поймал.

0

27.11.2020

Юра Ходырев

Andrey Belyakov
Там API по умолчанию принимает duration: https://k...

если duration превышен, должен быть экзепшн по таймауту. Но то есть у тебя соединение оборвалось без подтверждения

0

27.11.2020

Andrey Belyakov Автор вопроса

Юра Ходырев
если duration превышен, должен быть экзепшн по тай...

Это предположение, или где-то в документации такое есть? У меня как раз вызов poll() обернут в try/catch и нет исключения. С точки зрения проектирования API, действительно, это было бы ожидаемо, если оно бы было.

0

27.11.2020

Юра Ходырев

Andrey Belyakov
Это предположение, или где-то в документации такое...

Это только предположение

0

27.11.2020

Юра Ходырев · Accepted Answer

Юра Ходырев

А при вызове метода пол никакие таймеры на таймаут ставить нельзя? Как обычно когда web-request формируешь, можно указать время ожидания. Если оно истекло, то можно получить exception и с ним работать.

0

27.11.2020

52 похожих чатов

Привет, кто-нибудь знает, как со стандартным java api поймать кейс,

5 ответов

Похожие вопросы