因此，我使用quarkus和MicroFileReact性消息传递框架（使用smallrye-kafka连接器）以及rxjava2 flowable streams对象来接收/发送React性消息。我有一个微服务，它使用@incoming和@outgoing注解来正确地使用频道从后面的主题中提取消息，并将消息推送到主题中。
但是，现在我想修改它，这样我仍然可以从kafka主题中提取内容，并将json负载发送到rest端点。据我所知，没有与quarkus http兼容的smallrye连接器。有没有人知道有什么方法可以让它发挥作用？
示例函数

@Incoming("pre-check")
    @Outgoing("post-check")
    @Broadcast
    public Flowable<CustomMessage> publishToApi(CustomMessage customMessage) {

        LOGGER.info("Message received from topic = {}", customMessage);

        if (customMessage.ready) {
            return Flowable.just(customMessage);
        }
        else {
            return Flowable.empty();
        }
    }