-
本地是否支持kafka SSL连接?
我不会在quarkus中使用smallrye-kafka使用SSL连接到kafka主题。 我的代码在执行<code>mvn compile quarkus:dev</co -
具有开放自由度的反应式消息传递AMQP和服务总线
Open Liberty带有mpReactiveMessaging-1.0功能,其中包括一个Kafka连接器。 我想与Azure Service Bus集成,并且 -
无法确定为什么不编译smallrye / camel代码片段:骆驼上下文obj中没有订户方法?
smallrye文档(来自<a href="https://smallrye.io/smallrye-reactive-messaging/" rel="nofollow noreferrer">https://smallrye.io/smallrye -
为什么不能通过quarkus.io中的@Produces(MediaType.SERVER_SENT_EVENTS)将第二个客户端连接到服务?
我叫维克多。 我有一个具有<strong> quarkus-smallrye-reactive-messaging-kafka </strong>和<strong> quarkus-resteasy </strong> -
我的骆驼路线应用程序检测到其他应用程序发布的ampq消息(?),但无法处理,并出现“无类型转换器可用”错误。我该如何解决?
<strong>我的骆驼路线应用程序检测到其他应用程序已发布的ampq消息(已发布数字),但无法处理,并出 -
如何正确使用quarkus和smallrye做事件驱动的微服务
亲爱的, 我正在尝试做某种事件驱动的微服务。当前,当我使用Quarkus&Smallrye-Reactive消息传递扩展接收 -
AMQP消费者停止在第127条消息上接收
<strong> <em>问题</em> </strong>:发布者应用不断向Artemis经纪人发布AMQP消息-但是,消费者应用在第127位之后 -
Smallrye反应式消息传递集成测试
亲爱的, 我正在尝试使用<a href="https://www.testcontainers.org" rel="nofollow noreferrer">testcontainers</a>和<a href="https: -
如何在SmallRye反应性消息/ MicroProfile的反应性消息中请求消息?
我有一个使用消息并检查一些内部条件的方法。如果验证失败,我想拒绝该消息并将其放回队列,以便 -
使用io.smallrye.mutiny.Uni创建响应对象
我正在尝试学习在Quarkus框架上使用ReactiveMongoClient。 我以Uni身份发送回复部分成功 <pre><code>@GET -
Quarkus消息使用者并发(多线程)
在JMS世界中,您可以通过调整消息驱动bean(MDB)中的<strong> maxSession </strong>属性来轻松定义并发程度。 -
重新启动响应消息,例如重新配置后
如何重新启动或停止/继续响应式消息传递,例如改变间隔时间之后? 这个例子来自Quarkus指南:<a href="ht -
Uni <Void>如何在REST调用中获得失败或成功响应
服务器发送电子邮件后,我正在尝试设置简单的成功/失败响应。 但是,即使经过数小时的尝试, -
Quarkus从Kafka主题中提取并将JSON有效负载发送到REST端点
因此,我将Quarkus与Microprofile Reactive Messaging框架(带有SmallRye Kafka连接器)以及RxJava2 Flowable流对象一起用 -
Quarkus应用程序中Kafka de- / serializer中的CDI上下文
我有一个Quarkus项目,其中包含基于Kafka的Smallrye反应消息。因为我想使用“复杂的pojo”,所以我需要一 -
Quarkus:如何在Artemis中使用点对点消息传递?
我正在使用quarkus版本:<code>1.5.2.Final</code>和以下依赖项来包含响应消息传递(我在发送者和接收者项目 -
使用kafka的Quarkus反应式消息传递
我有两个微服务,一个生产者和一个消费者。生产者每两秒钟向kafka主题写一个数字增量。使用者有两个 -
动态使用Smallrye反应消息发布/订阅MQTT
我们尝试使用Smallrye反应消息发布和订阅MQTT协议。通过以下简单代码,我们设法将消息实际发布到特定 -
NPE消费Kafka主题
使用Quarkus 1.6.1和Smallrye反应消息传递框架,我有一个令人生畏的NPE消耗了Kafka主题。有趣的是,它不会在 -
Quarkus BackPressure配置
我使用quarkus smallrye反应性消息和kafka获得了以下堆栈跟踪: <pre class="lang-java prettyprint-override"><code>2020 -
Quarkus SmallRye Messaging Kafka Avro本机编译失败
我正在将带有Kafka的SmallRye反应性消息与Confluent Registry和AVRO一起使用。 如本博客<a href="https://quarkus.io/blog -
代理不可用后自动重启Quarkus Microservice
我有一个非常简单的Quarkus微服务,它使用smallrye反应消息传递(kafka)。有时我的kafka经纪人崩溃了,我 -
正在向ReactiveStream.publisher
我正在构建一个quarkus应用程序,它将接收和发送来自Rabbitmq的消息。 现在我可以从代理接收消息了 -
在Quarkus中启动后台进程
我需要在使用Quarkus编写的微服务中使用RabbitMQ的消息。我尝试将<em> smallrye-reactive-messaging </em>用于Quarkus -
从Kafka消费时,JPA事务成功后的确认消息
在Quarkus应用程序中,我想使用Kafka消息,并使用实体管理器将其信息保存在数据库中。 这是我到目 -
如何使用Smallrye Mutiny在vert.x事件总线中抛出异常
我正在尝试使用quarkus事件总线作为消息总线来实现简单的命令模式实现。 我正在使用请求/回复机制。 -
当在Quarkus中的无功消息传递中没有设置任何使用者时发生异常
我遵循了Quarkus官方消息传递指南,并创建了一个简单的示例来使用AMQP(Apache Artemis)来体验Reactive消息 -
Quarkus-Smallrye Kafka连接器:确认有效负载流
我有以下生产者: <pre><code> @Outgoing("platform-outcode-stats") public Multi<OutcodeStats> produceOutCod -
Quarkus Kafka - 批量/批量消息消费者
我想批处理。在我的用例中,发送 kafka 生产者消息是一一发送的。我想将它们作为消费者应用程序中的 -
Quarkus Reactive Messaging 不会使用 JMS 连接器和 SmallRye 实现启动单独的线程
在我的场景中,应用程序使用 CDI-Producer 从 JMS 队列读取消息。 <pre><code>@Produces public ConnectionFactory co