apache-camel 相关问题

替换 Camel 3.16 中删除的 newExchange()

我终于开始升级旧的 Camel 2.x 堆栈了。 WireTapDefinition.newExchange(Processor 处理器) 在 3.16 中被删除，我还没有找到任何如何替换它的示例。 什么

在bean中找不到：org.apache.camel.converter.stream.InputStreamCache

有一个下面的脚本，它抛出一个错误： .log("消息：${body}") //消息：{“caListID”：88186，“ciqWatchListID”：706596203} .setHeader(KafkaConstants.K...

消息模型中的“附件”是什么意思？

我读了《骆驼在行动》这本书。但我无法理解“附件”在其消息模型中的含义。 我知道什么是标题，例如“发件人信息”、“

Apache Camel 动态文件移动在 from() 和 toD() 端点中均不起作用

我正在使用apache Camel开发Spring Boot微服务，通过sftp与外部系统集成。我正在尝试在入站和出站方法中将文件移动到不同的文件夹。 S...

如何使用 CSVWriter 仅在 csv 中嵌入的逗号字符串上使用双引号？

这是我在输出 csv 中预期的结果格式： 标头1,标头2,标头3,标头4 莫妮卡、钱德勒、“瑞秋、罗斯”、乔伊 我目前的结果： 策略1： CSVWriter csvWriter = 新的 CSVWriter...

Apache Camel 拆分、标记化和流式传输 - 最后一个元素

我有以下骆驼路线 来自（“文件：//目标/输入/？删除= true”） .log("开始处理 [${header.CamelFileNameOnly}] ...") .split(body().tokenize(" &qu...

如何在Camel 4.x中使用rabbitmq组件迁移路由

我们基于Apache Camel 3.x实现了一个简单的路由引擎应用程序，支持动态路由配置加载：其他应用程序可以通过添加...来扩展路由引擎

使用 Apache Camel 上传到 S3 存储桶，如何使用 S3 托管密钥启用服务器端加密？

我使用 Apache Camel 和 aws2-s3 模块来访问 S3 存储桶。我正在使用端点 dsl 来编程我的路线。 我可以连接到存储桶并从存储桶中读取数据，但尝试访问时遭到拒绝

骆驼ZipAggregationStrategy的问题

我正在尝试通过 Camel v3.20.2 将目标文件夹中的所有文件压缩到一个 zip 存档中。 我已经尝试过文档中的示例并且它有效。我在输出/目录中看到文件 reports.zip 来自（“...

有没有一种方法可以将交换体（列表）分割成块而不是单元素交换？

有没有办法将交换体（列表）分割成比 1 元素交换更大的块？ 当使用大文件来处理时，我最终会得到大量的单行交换和大量的内存

camel 批处理间歇性轮询失败并出现 NullPointerException

我们使用camel kafka批量读取消息并处理它们，我们间歇性地看到轮询失败并导致消息丢失。 java.lang.NullPointerException：无法调用 &

Spring Boot 中的 Kamelet

我尝试定义一个简单的kamelet并在Camel Spring Boot路线中运行它。 my-kamelet.kamelet.yaml 位于 resources/kamelets api版本：camel.apache.org/v1alpha1 种类: 龟莱 元数据： 名字...

在Karavan中获取结果，获取状态：Postman中的500内部服务器错误，为什么？

当我使用 Postman 发帖时，Camel Karavan Apache 中没有错误，但为什么我得到状态 500？并且，API首先通过Kafka走另一条路线。 嗯，我尝试了很多方法让它看起来...

org.springframework.jms.connection.CachingConnectionFactory 提供用户名和密码

如何向 org.springframework.jms.connection.CachingConnectionFactory 提供用户名和密码？ （不是兔子）。 使用 Apache Camel，我正在尝试以下操作： ActiveMQ 组件

Json 验证日期时间骆驼

我目前遇到了camel中日期时间字段的json验证问题。我正在使用camel内置的json验证器，它接受参数json模式作为验证的参考......

Camel SpringBoot POST 返回对象而不是 JSON

我对Camel完全陌生，我创建了两个简单的REST端点（使用Camel 3.8.0和SpringBoot 2.4.3），一个GET和一个POST，就像这样 - @成分 公共类 CamelController 扩展

将 json-validator 结果添加到已验证的 json 对象中

我正在尝试根据 json 模式验证传入的 json 字符串，但如果验证失败，我不会抛出异常，而是希望将验证错误与vali一起转发...

Camel 路线测试 - 删除从所选步骤开始的所有步骤

我在根据测试需要调整Camel路线时遇到问题。 我定义了以下路线： 来自（来源） .routeId(ROUTE_GENERAL_ID) .wireTap(inputMetrics) ...

通过 Apache Camel 调用 NTLM 安全端点

我正在创建以下路由，它使用 NTLM 身份验证，但始终返回 401 并出现以下错误 来自（“直接：开始”） .setHeader(Exchange.HTTP_METHOD, () -&g...

Tibco ems 使用 apache 骆驼来安慰

是否有使用 apache Camel 从 tibco 队列到 solace 队列发送和接收消息的规定？ 如果是的话请帮忙如何？我们可以直接创建一条路线吗？ 我尝试过混合边缘，但那不是……