《apache》专题
-
Apache和Confluent kafka文档中的TopicNameMatches类的包引用错误
包org.apache.kafka.connect.transforms.predicates； https://github.com/a0x8o/kafka/blob/master/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/predicates/topicnamematches.java https:
-
Apache Storm Trident的喷动误差与Kafka积分
我正在使用OpaqueTridentKafkaSpout来消费来自Kafka的消息。下面是代码。我忽略了配置，因为这会导致同一kafka消息在多个批处理中到达。 当Kafka喷口开始时，我得到以下错误一次，但之后运行平稳。
-
Apache Camel:无法删除文件并锁定
我正在使用ApacheCamel文件组件从本地目录读取数据并上传到AWS S3存储桶。这条路线在过去工作得很完美，但现在每天都有一些文件出现问题。 在我迄今为止的调试调查（3天的痛苦）中，我发现该路由到达了类，并且在交换上没有设置任何异常（供参考，请参阅下面前面提到的类的相关代码）。考虑到没有任何异常，我似乎无法弄清楚为什么方法从不针对特定文件触发。有问题的文件没有/没有任何异常；但是，在所有逻辑
-
File component（Apache camel）delete=true参数在windows中不工作Apache Camel File组件在Windows7中无法正常工作，因为它在Linux工作没有任何问题。 我的要求： 文件处理后，必须从目录中删除文件。在Windows中，因为。camelLock文件没有正确删除。 多次尝试后，只有Apache camel可以从目录中删除该文件。如果attemt未能从目录中删除该文件，则会引发异常。 如果我的目录中只有一个文件，它就可以正常工作，但是如果我有多
-
在JavaDSL中为apache骆驼路线编写自定义方法
我可以在Camel中编写自己的处理器定义方法并在我的路由中使用它吗？ from在Route定义中实现，to在Processor定义中实现。就像这样，如果我想实现setTimeOut方法并在java DSL中使用它，我该怎么做？ PS：我不想将超时作为Httpclient查询参数传递给HttpUri。 有人能帮忙吗？
-
Apache Camel 2.10.7-监视文件系统中文件的删除
我在servicemix中使用camel 2.10.7非常成功地将文件从本地文件系统馈送到我的应用程序。 文件应保留在文件系统上，因此我使用这样的配置。 from uri=“file:../ange data/vessers？noop=true 如果我触摸/更新文件系统上的文件，这将非常有效。 唯一的问题是：如何在我的Java代码中检测到文件已被其他人或进程从文件系统中删除？ 通过研究手册页面，找
-
如何在Java DSL路由中使用apache Camel在try catch block中使用choice
如何在Java DSL路由中使用Apache Camel在try catch block中使用choice？ 我的情况是，我需要以下结构： 路线-- 到目前为止，我尝试了以下几行： 但是我在 你能建议用JavaDSL在try catch块中使用“选择”的方法吗？
-
Apache Camel重新排序程序不工作
我正在尝试使用Apache Camel运行一个简单的重新排序程序。该程序使用Java DSL对传入的Java消息重新排序。当我运行这个程序时，消息会被写入文件夹，但根据标题值或消息正文中单个单词的字母顺序，不会出现任何特定的顺序。Camel创建的文件仍然无序，就好像DSL函数什么都没做一样。 如何让这个程序像方法那样对消息进行实际排序？此外，如何让这个程序重新排序，然后以正确的排序顺序将消息聚合到
-
Apache camel发送一条简单的消息
我有一个简单的camel MINA服务器，使用JAVA DSL，我的运行方式与这里记录的示例类似： 独立运行骆驼并让它在JAVA中继续运行 MINA 2组件 我正在尝试创建一个托管在mina：tcp://localhost:9991（又名MyApp_B）的示例应用程序，该应用程序向托管在mina：tcp://localhost:9990（又名MyApp_A）的服务器发送一个非常简单的消息。 我想发
-
Apache Camel：查询参数与标头参数
我目前正在试用Apache camel（作为路由引擎）。我知道Camel支持多个DSL，并且可以使用Java（JavaDSL）或Spring（Spring DSL）进行配置。 问题： 我有以下Spring DSL配置。这个想法是，如果传入的请求具有名为“name”的头参数，它将命中当子句或其他方式将请求路由到google： 我希望上面的配置只适用于Header参数。然而，我注意到，这种配置甚至适用
-
Apache Camel将JSON转换为JMS
我正在尝试将JSON格式的路由中的信息转换为JMS格式，以便将其发送到主题。 看看这些文件，我发现： 这里的解释是否正确，我们已经将队列中的消息编组为JSON，然后在将其发送到另一个队列时，它已转换回JMS消息？如果没有，我们如何使用JavaDSL实现这种转换？此外，是否可以沿驼峰路径向JSON添加键值对？ 谢谢。
-
Apache Camel使用数据库在集群中运行的路由的单个实例
我在两台服务器上部署了Apache Camel应用程序，它们使用JMSendpoint。我想确保一次只使用一条来自jmsendpoint的驼峰路由。我可以用于集群的唯一选项是使用数据库作为锁存储。Apache Camel是否提供了这样的功能？
-
使用Spring DSL的Apache Camel
如何将属性文件与Apache Camel一起使用以引用可配置的属性例如，如果有从文件夹读取文件的路由，如何在属性文件中配置该文件夹位置。使用Spring DSL
-
将属性文件与Apache Camel一起使用
属性文件如何与Apache Camel一起使用，以引用可配置的属性。例如，如果有从文件夹读取文件的路由，那么如何在属性文件中配置该文件夹位置。我正在使用JavaDSL。
-
如何使用TestNG框架和Apache POIJavaWebDriver在Excel中写入数据
我想在Excel中存储用户名和密码，无论我在使用WebDriver的任何应用程序中输入什么。我使用TestNG框架和Apache POI将数据写入Excel。但是我得到。请告诉我如何使用Excel工作WebDriver。