- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
如何使用 quarkus + kafka + smallrye 处理流处理异常?
我的代码与 quarkus 指南( https://quarkus.io/guides/kafka#imperative-usage )上的命令式生产者示例非常相似
import io.smallrye.reactive.messaging.annotations.Channel;
import io.smallrye.reactive.messaging.annotations.Emitter;
import javax.inject.Inject;
import javax.ws.rs.POST;
import javax.ws.rs.Path;
import javax.ws.rs.Consumes;
import javax.ws.rs.core.MediaType;
@Path("/prices")
public class PriceResource {
@Inject @Channel("price-create") Emitter<Double> priceEmitter;
@POST
@Consumes(MediaType.TEXT_PLAIN)
public void addPrice(Double price) {
priceEmitter.send(price);
}
}
ProducerRecord<String, String> record = new ProducerRecord<>("topic-name", key, value);
producer.send(record, new Callback() {
@Override
public void onCompletion(RecordMetadata metadata, Exception exception) {
logger.info(record.toString());
if (exception != null) {
logger.error("Producer exception", exception);
}
}
});
最佳答案
有一个section of the docs on Acknowlegement
@Incoming("i")
@Outgoing("j")
@Acknowledgment(Acknowledgment.Strategy.MANUAL)
public CompletionStage<Message<String>> manualAck(Message<String> input) {
return CompletableFuture.supplyAsync(input::getPayload)
.thenApply(Message::of)
.thenCompose(m -> input.ack().thenApply(x -> m));
}
关于java - Quarkus + Kafka + Smallrye 异常处理,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/60005697/
如何使用 quarkus + kafka + smallrye 处理流处理异常? 我的代码与 quarkus 指南( https://quarkus.io/guides/kafka#imperativ
目前,我正在尝试基于Kotlin中的Maven,Quarkus和SmallRye Reactive Messaging编写“通知服务”。 作为基础,我有一个使用Java的示例,它可以正常工作,并且我试
我有一个如下所示的请求: @Path("/v1") @RegisterRestClient @Produces("application/json") public interface VaultCl
我们尝试使用 smallrye 响应式(Reactive)消息传递来发布和订阅 MQTT 协议(protocol)。我们设法通过以下简单代码将消息实际发布到特定主题/ channel import i
我想使用这个扩展:[Quarkus Smallrye Reactive Messaging Kafka] 但在我的应用程序中,主题的名称是事先不知道的,它是根据运行时从用户收到的消息指定的。如何在没有
在 RxJava 2 和 Reactor 中有一个 switchIfEmpty like 方法在当前流中没有元素时切换到新流。 但是当我开始使用Minuty ,当我将我的 Quarkus 示例转换为使
其他响应式(Reactive)库如 project reactor 为 Publishers 提供了排序方法,但在 mutiny 中没有这样的方法。他们的文档甚至没有谈论它。 https://smal
我正在尝试学习在 Quarkus 框架上使用 ReactiveMongoClient。 我以 Uni 发送响应部分成功> @GET @Path("/unpaginated") public Uni>
我正在尝试使用 quarkus-smallrye-graphql 扩展。而且似乎我不能使用任何安全注释,例如 @已认证 在用 注释的类中@GraphQLApi .我之前尝试过直接使用 smallrye
我在我的 Quarks 应用程序 中使用 Smallrye Mutiniy react 库,因为它在 Quarks 应用程序中得到原生支持。 我正在尝试为服务类编写单元测试。我不确定如何为返回 Uni
我正在尝试将 Artimis-MQ 客户端迁移到 quarkus 微服务。当尝试发送消息时,我始终收到“流未连接”错误。 我尝试遵循答案中的建议(使用 microprofile-reactive-me
我在我的 Quarks 应用程序 中使用 Smallrye Mutiniy react 库,因为它在 Quarks 应用程序中得到原生支持。 我正在尝试为服务类编写单元测试。我不确定如何为返回 Uni
smallrye 文档(来自 https://smallrye.io/smallrye-reactive-messaging/ )引用了一个我在编译时遇到问题的示例代码片段... 即, 10.4. U
下面是我尝试使用 Apache Camel 响应式(Reactive)流解决方案,跨 JVM 将发布者连接到订阅者(Camel 路由的代码如下所示) 为了实现跨 JVM 的通信,似乎需要一个“代理”服
我是一名优秀的程序员,十分优秀!