Кафка живость с кваркусом Smallrye Kafka ⇐ JAVA
-
Гость
Кафка живость с кваркусом Smallrye Kafka
Я новичок в Quarkus и пытаюсь отправить некоторые данные в Kafka. Для этого я использую smallrye-kafka:
io.quarkus quarkus-smallrye-reactive-messaging-kafka Для отправки данных я использую вот такой эмиттер:
@Inject @Channel("мой-канал") частный эмиттер ; emitter.send(Record.of(hotel.getId(), отель)) Можно ли проверить работоспособность сервера Kafka и в случае возникновения ошибки обработать исключение?
Или доступна какая-то документация, описывающая, как это сделать?
Заранее большое спасибо за ваши ответы и потраченное время.
Я новичок в Quarkus и пытаюсь отправить некоторые данные в Kafka. Для этого я использую smallrye-kafka:
io.quarkus quarkus-smallrye-reactive-messaging-kafka Для отправки данных я использую вот такой эмиттер:
@Inject @Channel("мой-канал") частный эмиттер ; emitter.send(Record.of(hotel.getId(), отель)) Можно ли проверить работоспособность сервера Kafka и в случае возникновения ошибки обработать исключение?
Или доступна какая-то документация, описывающая, как это сделать?
Заранее большое спасибо за ваши ответы и потраченное время.
