Кафка живость с кваркусом Smallrye Kafka ⇐ JAVA

[Гость]

Я новичок в Quarkus и пытаюсь отправить некоторые данные в Kafka. Для этого я использую smallrye-kafka:

io.quarkus quarkus-smallrye-reactive-messaging-kafka Для отправки данных я использую вот такой эмиттер:

@Inject @Channel("мой-канал") частный эмиттер ; emitter.send(Record.of(hotel.getId(), отель)) Можно ли проверить работоспособность сервера Kafka и в случае возникновения ошибки обработать исключение?

Или доступна какая-то документация, описывающая, как это сделать?

Заранее большое спасибо за ваши ответы и потраченное время.