Описание тега smallrye-reactive-messaging

Вопросы с тегом
0 ответов

Интеграционное тестирование реактивного обмена сообщениями Smallrye

Dears, я пытаюсь сделать какое - то тест интеграции с Smallrye реактивным сообщений с использованием https://www.testcontainers.org/ и приварной блока и JUnit 5. Вот мой тестовый код: @EnableWeld public class MicroprofileReactiveMsgIT { private stat…
08 янв '20 в 21:00
1 ответ

Отправить сообщение amqp с заголовками в quarkus

Я хочу отправить POJO Java (ну Kotlin) как JSON в сообщении AMQP в RabbitMQ с помощью Quarkus. @Path("/amqp") class TestSource { @Inject @Channel("amqpwrite") lateinit var emitter: Emitter<MonitoringStatusDto> @POST @Path("/send") fun sendMsg(…
03 мар '20 в 18:15
0 ответов

NPE, использующий тему Kafka

Я получил устрашающий NPE, использующий тему Kafka с использованием Quarkus 1.6.1 и среды реактивного обмена сообщениями Smallrye. Интересно то, что это не происходит при низкой скорости передачи сообщений (~100 сообщений / сек), а, кажется, происхо…
30 июл '20 в 15:00
1 ответ

Uni <Void> как получить ответ об ошибке или успехе при вызове REST

Я пытаюсь настроить простой ответ об успехе / неудаче после того, как сервер отправил электронное письмо. Однако даже после нескольких часов перебора множества вариантов я все еще не получаю правильного ответа. Пример кода, который просто дает ответ…
13 июн '20 в 19:38
1 ответ

Приложение My Camel route обнаруживает опубликованное другим приложением сообщение ampq (?), Но не может обработать сообщение об ошибке "Нет доступного преобразователя типов". Как я могу решить?

Приложение My Camel route обнаруживает опубликованное другим приложением сообщение ampq (публикует числа), но не может обработать сообщение об ошибке "Нет доступного преобразователя типов". Как я могу решить?. "org.apache.camel.NoTypeConversionAvail…
23 ноя '19 в 06:38
2 ответа

Поддерживают ли Quarkus и MicroProfile схему Avro реестра Confluent Schema?

Confluent SchemaRegistry не работает с Quarkus и MicroProfile в конечном итоге с ошибкой ниже ***********ERROR Caused by: io.confluent.common.config.ConfigException: Missing required configuration "schema.registry.url" which has no default value. Я …
27 окт '19 в 22:29
1 ответ

Перезапустите реактивный обмен сообщениями, например, после перенастройки

Как я могу перезапустить или остановить / возобновить реактивный обмен сообщениями, например, после изменения интервала времени? Этот пример взят из руководства Quarkus: https://quarkus.io/guides/kafka-streams @Outgoing("temperature-values") public …
06 июн '20 в 22:00
2 ответа

Измените хост и порт kafka при использовании Quarkus и SmallRye

Я не могу изменить хост и порт Kafka, когда мне нужно запустить его через docker-compose. Я хочу использовать одну и ту же docker-compose для запуска своих сервисов и Kafka. поэтому мне нужно сменить хост Kafka. Я безуспешно пытался указать следующу…
22 окт '19 в 15:16
0 ответов

Поддерживается ли SSL-соединение kafka в нативном?

Я не хочу подключаться к теме kafka с помощью SSL, используя smallrye-kafka в quarkus. Мой код работает при выполнении mvn compile quarkus:dev. mvn clean package -Pnativeуспешно. Но когда я запускаю собственный двоичный файл, он не работает, потому …
05 ноя '19 в 13:46
1 ответ

Реактивный обмен сообщениями AMQP и служебная шина с Open Liberty

Open Liberty поставляется с функцией mpReactiveMessaging-1.0, которая включает коннектор Kafka. Я хочу выполнить интеграцию со служебной шиной Azure и использую соединитель Smallrye AMQP (версия 1.0.8). При попытке отправить в очередь служебной шины…
09 ноя '19 в 12:29
1 ответ

Quarkus + Kafka + обработка исключений Smallrye

Как я могу обработать исключение при потоковой обработке с помощью quarkus + kafka + smallrye? Мой код очень похож на пример императивного производителя в руководстве по quarkus (https://quarkus.io/guides/kafka) import io.smallrye.reactive.messaging…
31 янв '20 в 17:20
1 ответ

Emitter <>. Send в SmallRye Reactive Messaging не отправляется в Kotlin через брокера AMQP с Quarkus

В настоящее время я пытаюсь написать "службу уведомлений" на основе Maven, Quarkus и SmallRye Reactive Messaging в Kotlin. В качестве основы у меня есть пример на Java, который отлично работает, и я пытался "перевести" его на Kotlin. Я хочу, чтобы о…
16 сен '19 в 19:18
1 ответ

Не можете определить, почему фрагмент кода smallrye/camel не компилируется: нет метода подписчика в объектном контексте camel context?

В документации smallrye (из https://smallrye.io/smallrye-reactive-messaging/) приводится пример фрагмента кода, который у меня возникают при компиляции... т.е. 10.4. Using Camel Route in @Incoming method Here is an example of method annotated with @…
19 ноя '19 в 05:26
0 ответов

Потребитель AMQP перестает получать 127-е сообщение

ПРОБЛЕМА : приложение-издатель постоянно публикует сообщения AMQP для брокера Artemis, но приложение-потребитель перестает получать сообщения после 127-го. Fwiw - По совпадению, заметил отрывок с веб-страницы Смоллри: "размер буфера по умолчанию (12…
03 янв '20 в 07:42
1 ответ

Как отправить сообщение на Кафку

Я новичок в реактивном программировании и пытаюсь реализовать самый простой сценарий. Я хочу отправлять сообщение в kafka каждый раз, когда файл помещается в определенную папку. Я думаю, что плохо понимаю основы... так что, пожалуйста, не могли бы в…
19 фев '20 в 17:46
1 ответ

Реактивный обмен сообщениями Quarkus с kafka

У меня два микросервиса, производитель и потребитель. Производитель записывает приращение числа каждые две секунды в тему кафки. У потребителя есть два запущенных экземпляра, использующих эти приращения. Я заметил несколько странных вещей, которые х…
12 июл '20 в 22:14
0 ответов

Управление Quarkus BackPression

Я получил следующую трассировку стека, используя реактивный обмен сообщениями quarkus с kafka: at org.jboss.threads.ContextClassLoaderSavingRunnable.run(ContextClassLoaderSavingRunnable.java:35) at org.jboss.threads.EnhancedQueueExecutor.safeRun(Enh…
13 авг '20 в 23:43
0 ответов

Как запрашивать сообщения в SmallRye Reactive Messaging / Reactive Messaging для MicroProfile?

У меня есть метод, который потребляет сообщения и проверяет некоторые внутренние условия. Если проверка не удалась, я хочу отклонить сообщение и вернуть его в очередь, чтобы оно позже поступило к потребителю. Я не нашел специального API в Reactive M…
31 янв '20 в 14:08
1 ответ

Исключение десериализации Quarkus Kafka Streams/Reactive Messaging

Привет, я экспериментировал как с Kafka Streams, так и с MP Reactive Messaging, чтобы читать из темы Kafka, а затем возвращаться к ней. Ошибка Kafka Streams - org.apache.kafka.streams.errors.StreamsException: Deserialization exception handler is set…
17 июл '20 в 22:53
2 ответа

Как правильно выполнять микросервисы, основанные на событиях, с кваркусом и smallrye

Уважаемые, я пытаюсь создать какие-то микросервисы, управляемые событиями. В настоящее время мне удалось получить сообщение от Kafka и обновить запись в базе данных, когда сообщение получено с помощью расширения обмена сообщениями Quarkus & Smallrye…
26 дек '19 в 09:28