在 Quarkus 中将 CloudEvent 从 HTTP POST 中继到 Kafka

问题描述

我有一个来自 HTTP POST 的传入 io.cloudevents.CloudEvent 对象，并且想使用 Quarkus 使用 this approach 将对象按原样中继到 Kafka 主题。有没有办法做到这一点？谢谢。


----RESTResource.java-----

    @Inject
    @broadcast 
    @Channel("mychannel") Emitter<CloudEvent> ceEmitter;

    @POST
    public CompletionStage<Response> sendEvent(CloudEvent object) {
        return CompletableFuture.supplyAsync(() -> {
            Set<ConstraintViolation<CloudEvent>> violations = validator.validate(object);
            ceEmitter.send(object);
            return Response.accepted().build();
        });
    }


-----KafkaProducer.java-----
        @Incoming("mychannel")
        @Outgoing("mytopic")
        public Message<CloudEvent>  generate(CloudEvent ce) {
            return Message.of(ce);
        }

mp.messaging.outgoing.mytopic.value.serializer=??? mp.messaging.incoming.mytopic.value.deserializer=???

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）

cloudevents quarkus