问题标签 [apache-camel-k]

我想在 camel-k 中建立一条集成路线。但是为了更好的调试（fe添加断点）我已经在一个maven项目中用camel构建了集成路由。该项目现在在多个文件中包含多个类作为依赖项（逻辑和单独的处理器）。该路线工作正常，现在我想用camel-k将它部署在kubernetes中。在使用 kamel cli 构建路线时，是否有一种方便的方法可以打包所有需要的类？这样，在同一个项目中，两种用途（骆驼和骆驼 k.）都是可能的。在其他讨论中，已经指出的一种解决方案是将类打包为 jar 并将它们作为 maven 依赖项添加到 modline 中，但是使用这种方法，每次进行更改时都必须重新打包。我还尝试使用 kamel run 命令加载所有类，

我在 Apache Camel 中使用 AHC-WS 组件连接到使用 WSS 的 websocket 服务器。当服务器关闭连接时，我得到了 IOException 异常并且我的 errorHandler 开始重新传递，但似乎重新传递失败（它只重新启动一次，尽管我指定 10 为最大重新传递），解决这个问题的唯一方法是重新启动我的骆驼手动路由以再次连接到 websocket 服务器。

最近开始测试用camelk开发，发现配置settings.xml的时候不行。

这是settings.xml：

如何使用 Camel-K（版本 1.6.0）连接到 MongoDB？

我尝试直接在 MongoDB Camel 组件 URI 上设置主机名：

但它坚持打电话127.0.0.1:27017：

可能我应该在属性文件中设置类引用，如下所示：

但是我不确定那应该是什么课程？- 以及要设置哪些其他属性名称？

我要部署到 Kubernetes 集群（OpenShift CodeReady 容器，使用命令kamel run MongoDBTest.java --dev）的完整 Camel-K 集成 Java 文件如下所示：

在 integration.properties 文件中我有：

• 应该有其他的类参考吗？
• 如果没有在 MongoDB Camel 组件 URI 上设置主机名，那么下面应该有哪些属性camel.beans.mongoBean？

更新：问题已在 Camel K GitHub 问题下得到解答： https ://github.com/apache/camel-k/issues/2693

我有一个 Camel K 项目，它使用端口 4739。现在我只能在登录 pod 容器时向该端口发送数据。

我正在尝试在容器外发送数据，有人知道如何配置吗？

以下命令已尝试但似乎不起作用...

我的理解是容器生活在一个吊舱内。首先我们需要将容器端口暴露给 pod，然后使用 service 将端口暴露给外部，不幸的是我没有找到任何与服务端口相关的命令行。

我已将主题保存在标题中，并尝试在 Kafka URL 中访问它，如下所示：

不幸的是它说 Kafka URL 无效：</p>

我已经尝试替换to(...)with.log("${header.topic}")并且可以在日志行中打印预期值。

有谁知道是什么导致了这个问题，我应该逃避美元符号还是花括号？

更新

Squake 和 Nicola 的答案都正常工作。要检查生成的日志文件，您需要访问容器并检查正确的目录：

原始问题

我有一个使用 kamel 运行的集成吊舱：

我已经登录了路线

我可以使用以下命令检查日志行：

然后我可以使用以下方法访问 pod：

我试图检查文件夹/var/log，不幸的是没有相关的日志文件。

我对此有两个问题：

• 集成 pod 中的日志文件位置在哪里？
• 如何指定日志文件位置？

谢谢

我的 Camel K 路线出现 OutOfMemoryError。我正在使用SEDA（一个生产者和多个消费者）并以每秒 10,000 个事件的速度提供事件，即使我使用多个消费者也会引发错误，有人知道如何提高性能吗？

我试图增加消费者数量，但问题尚未解决，我尝试增加内存，但内存队列占用了太多内存。

错误信息：

这是我的 SEDA 路由的源代码：

我有一个包含多条路线的 Camel K 应用程序（每条路线都是一个 Java 文件）。我的目标是管理路线状态，例如启动某些路线并停止其他正在运行的路线。

目前我使用手动启动和关闭路由kamel run XXX.java --pod-template pod_template.yaml --property=file:logging.properties ...，我想知道通过 API 实现管理路由状态的最佳方法是什么？

我的目标是使用 API 实现以下目标：

• 开始一条路线
• 停止路线
• 列出可用路线

我已经在apache/camel-k下提出了这个问题，但仍然对答案中提到的集成 CRD 感到困惑。

我发现 Camel K 有 API Camel K API不幸的是我还没有弄清楚如果可能的话如何调用 API？

有人可以分享知识并帮助我吗？谢谢！

我1.6.1在 Google Kubernetes Engine 上使用 camel-k。我想将容器图像推送到 Google Cloud Registry，但如果图像未缓存在 gcr 中，则从我们的组织 Artifactory 中提取图像。

由于这个问题，我使用 Kaniko 作为构建工具，我认为它会起作用，如果你给 Kaniko 两个容器注册表：第一个将图像推送到 gcr，第二个作为后备，如果构建需要 gcr 中不存在的图像. 但骆驼-k集成平台似乎不支持这一点。Go 规范说：

我的平台配置如下所示：

如何在此设置中设置多个容器注册表以将 camel-k 集成图像推送到 gcr 并从 Artifactory 而不是默认的 DockerHub 中提取不存在的图像？