Apache Camel：我需要使我的FTP消费者路由成为事务性的吗？
include=.*.xml&delay=60s&consumer.bridgeErrorHandler=true&throwExceptionOnConnectFailed=true&binary=true&move=.done&soTimeout=300000
另一个问题是：您能给出一个建议，为这种情况添加另一个有用的完整ftp消费者属性吗？
共有1个答案
如果F.E.通过移动文件，IOException就会发生
根据GenericFileEndpoint.java，您可以使用setmoveFailed()来定义如果移动失败将文件移动到哪里。FTPendpoint应该继承该选项，请参见此处：FtpEndpoint
我不认为您需要使您的endpoint事务性。
-
这是我的骆驼上下文摘录：- 下面是日志中的一个片段：- 即使是也不能阻止堆栈跟踪。现在我已经发现，如果我向JMS消费者添加disableReplyTo=true，那么stacktrace就不会显示哪一个是优秀的。
-
我有几条骆驼路由，在从DB读取数据时，我在Exchange对象中设置了一个头，其中一条路由的名称为FILE_NAME。作为下一步，这条路由将进一步转到我的FTP路由，文件应该在那里下载。问题是FTP路由没有接收到我正在使用的contentEnricher的前一条路由的头。这是官方行为：http://camel.apache.org/content-enricher.html。但是，可以动态构造FT
-
是否有一种方法以编程方式访问和打印使用者滞后偏移，或者说使用者读取的最后一条记录的偏移与某个生产者写入该使用者分区的最后一条记录的偏移之间的位置差。 要知道我的最终目标是将这个值发送到prometheus进行监视，我应该在上面添加哪些语句来得到滞后偏移值？
-
我有一个使用Spring Boot相关项目的项目。我想在项目中使用Kafka消费者和生产者的Transactional功能。我需要尽可能高效地在Kafka中生成大量消息。所以我需要一个多线程消费和生产来满足这个要求。如何使用Spring boot开发多线程消费者和生产者？
-
根据我的理解，当数据库事务跨越微服务时，我们可以通过使用message-broker(kafka、RabbitMQ等）通过发布事件来解决这个问题，这样订阅者微服务就可以通过监听这些事件来更新他们的数据库。 在异常情况下，我们可以发送故障事件，以便订阅服务器服务更新它们的状态。 我们真的需要事件来源吗？
-
我不知道这个，但我得到了以下路线的stacktrace： 有什么明显的问题吗？