apache-camel 相关问题

Camel 中对 Kafka 生产者/消费者的事务支持

我的目标是构建一个交易骆驼路线，包括： JMS->DB->KafkaProducer KafkaConsumer->DB->JMS 从相关的 JIRA 和 Camel 文档中，我可以看到交易

骆驼路线的事务支持涉及Kafka Producer/Consumer +JMS+DB

我的目标是构建一个交易骆驼路线，包括： JMS->DB->KafkaProducer KafkaConsumer->DB->JMS 从相关的 JIRA 和 Camel 文档中，我可以看到交易

Spring Boot 2.5.0 使用哪个版本的 Apache Camel SpringBoot Starter

来自 Maven Central：https://mvnrepository.com/artifact/org.apache.camel.springboot/camel-spring-boot-starter 这就是依赖似乎是什么： org.apache.camel.springboot » 骆驼弹簧引导-

如何将骆驼身体转换为其属性之一

我尝试使用springboot设置一个简单的骆驼路线。 它从数据库表中读取单个列，并为每一行在 artemis 队列中放置一条消息。 很简单，但我努力得到...

用 Camel 日志中的正则表达式替换 Body

我想在 Camel 日志中用 * 替换某些字符串，为此我将以下代码与正则表达式一起使用，效果很好： .log("消息正文：${body.replaceAll('(?:.+?) 我想在 Camel 日志中用 * 替换某些字符串，为此我将以下代码与正则表达式一起使用，效果很好： .log("message body: ${body.replaceAll('<Name1>(?:.+?)</Name1>', '<Name1>*****</Name1>')}") 但是当我只想替换前 5 个字符时，我使用以下代码： .log("message body: ${body.replaceAll('<Name1>(.{1,5})(.*)</Name1>', '<Name1>*****$2</Name1>')}") 但是是给我以下空指针异常的错误： 任何帮助将不胜感激，在此先感谢..

如何在共享 NFS 挂载的多 pod 环境中配置 Apache Camel 路由

我正在尝试在多 pod 云环境中实现基于 Apache Camel 的文件观察器，但最终会出现重复处理。我想知道 Apache Camel 是否有任何内置功能

Camel 停止从 JMS 队列中取出消息

我们在 Karaf OSGI 服务器中使用 Camel 和 ActiveMQ。 我们有一个路由，它从 JMS 队列中取出消息并将它们传递到 HTTPS 端点。这是构建路由的 java 代码： ...

如何使用 Camel 替换 CSV 字段的值？

我有以下要求： 对于 CSV 文件中的每条记录，读取其名为 startValue、endValue 和 change 的三个字段中包含的值。 将变化计算为 (endValue-startValue)/

如何避免使用 Apache Camel 将数据存储在内存中

在 apache camel 中，我调用 rest 服务来获取所有用户，然后我需要验证每个用户，然后对每个用户进行 rest 调用以获取产品，然后将其写入 .txt 文件。 来自（“明星...

如何在 Apache Camel 中创建自定义转换器

`我必须使用 apache camel 将 json 转换为 json，为此我想在 apache camel 中创建一个自定义转换器。但是做不到。 我尝试通过扩展

How to set headers with reactive-streams in camel?

我有以下调用 camel 中的路由，我需要设置一些通过参数到达的标头，但是，to 方法只允许将数据发送到路由。我怎样才能设置hea ...

Apache Camel 支持 solace 吗？

我正在尝试搜索 apache camel 是否支持 Solace。根据我的搜索，看起来好像没有，但是当我在 chatGPT 上搜索时，它说 - 是的，它受支持。 我搜索了对 https://re...的依赖

apache 骆驼中的解组（JSON）

我是apache camel的新手。我想用 apache camel 做一些简单的任务。我在这个 url http://localhost:8080/users/ 上有可用的 json 数据。我的休息服务中有 json 数据。但是我...

无法将交换主体转换为自定义对象

我正在尝试将 jwt 令牌转换为对象以使用 spring DSL 获取访问令牌 我正在尝试将 jwt 令牌转换为对象以使用 spring DSL 获取访问令牌 <to uri="ref:oauthTokenEndpoint" /> <log message="Auth Token Response is ${body} " loggingLevel="INFO" /> <choice> <when> <simple>${header.CamelHttpResponseCode} == '200'</simple> <to uri="bean:getResponseCode?method=processOAuthToken" /> <to uri="direct:sendEventPostServiceCall" /> </when> <otherwise> <log message="[POST] Error getting token response code is ${header.CamelHttpResponseCode} " loggingLevel="INFO" /> </otherwise> </choice> 这里是流程代码 TokenResponse tokenResponse = exchange.getIn().getBody(TokenResponse.class); logger.debug("exchange body Token Response "+tokenResponse); exchange.getOut().setHeader("jwt", tokenResponse.access_token ); 这是 TokenResponse 类 public class TokenResponse { String token_type; String expires_in; String ext_expires_in; String access_token; public String getToken_type() { return token_type; } public void setToken_type(String token_type) { this.token_type = token_type; } public String getExpires_in() { return expires_in; } public void setExpires_in(String expires_in) { this.expires_in = expires_in; } public String getExt_expires_in() { return ext_expires_in; } public void setExt_expires_in(String ext_expires_in) { this.ext_expires_in = ext_expires_in; } public String getAccess_token() { return access_token; } public void setAccess_token(String access_token) { this.access_token = access_token; } } 我总是在 process 方法中得到 null。我需要在这里设置任何转换器或 Json ObjectMapper 吗？ 我发现，在处理令牌之前记录是有问题的，一旦我删除了以下记录语句， 我能够在exchange.getIn().getBody...中收到代币

camel 生产者在处理 json 时不工作

`我想读取一个excel文件并通过camel REST将其转换为json文件。但是当我试图访问 我的路由中的 API 表示 Route: route1 started and consuming from: servlet: /api/

Apache Camel 抛出 NoSuchEndPointException

我无法从特定文件夹读取文件 这是我的 routebuilder 代码 @Component("RequestFileRouteBuilder") 公共类 RequestFileRouteBuilder 扩展 RouteBuilder{ ...

Apache Camel SFTP 正在控制台中询问用户名和密码

虽然我已经添加了用户名和密码，但骆驼路线仍然在控制台中要求输入用户名和密码。 依赖 - org.apache.camel...

How to pass header from Processor to Transformer - Kafka Connector - Kamelets

我正在处理器中设置一些自定义标头， 公共类 CustomProcessor 实现处理器 { @OverRide public void process(Exchange exchange) 抛出异常 { 交换.getMessage().

尝试在 autoStartup 设置为 false 的情况下通过 CamelContext 运行 Camel 路由

我有以下 Camel 路线，我试图直接通过 CamelContext 运行，并将 autoStartup 设置为 false @成分 `@ConfigurationProperties() 公共类 S3IntegratorRoute 扩展

如何禁止在 seda 端点之间传递属性？

使用 seda 端点我看到 Exchange 属性在端点之间传递。 例子： sedaRouteA.setProperty("myProperty", 1) -> 发送 -> sedaRouteB.getProperty("myProperty&...