如何“忽略”从Apache Camel文件消费者获取的交换
我有一个批处理文件使用者，它正在轮询一个公共目录，许多不同的进程将文件拖放到该目录。这些文件通过文件名上的guid“成批”在一起。一旦某个特定批次完成，应用程序就会删除。完成文件以触发camel文件使用者。
我的问题是，我正在试图找到一种可能“忽略”邮件/交换的方法，这些邮件/交换可能包含我不想处理的文件（即…不属于我当前批处理的一部分）。
此外，我希望“被忽略”的交换不被camel处理（即...未移动到。已处理目录）。
我目前正在考虑将消息过滤器作为一种潜在的方法来实现这一点，尽管我不确定它是否能完全满足我的不处理要求。
有什么建议吗？
共有1个答案
您可以在文件组件上使用“include”或“antinclude”（或“exclude”和“antexclude”）参数，仅处理基于regex或ant模式的特定消息。未处理的文件将不会被移动或触摸。
如果您需要一组比正则表达式或ant模式更复杂的规则，您可能需要编写自己的自定义可插拔过滤器，然后您可以使用“过滤器”参数指定该过滤器。
有关上述内容的更多详细信息，请参阅此处：
http://camel.apache.org/file2.html
-
我正在使用事务性KafkaProducer向主题发送消息。这个很管用。我使用的是具有read_committed隔离级别的KafkaConsumer，而我的seek和seekToEnd方法存在问题。根据文档，seek和seekToEnd方法给出了LSO（上次稳定偏移量）。但这有点让人摸不着头脑。因为它给我的价值总是一样的，主题结束了。无论最后一个条目是（由生产者提交的）还是中止的事务的一部分。例如
-
我要求从主题中读取消息，对它们进行批处理，然后将批处理推送到外部系统。如果批处理因任何原因失败，我需要再次使用同一组消息并重复该过程。因此，对于每个批处理，每个分区的 from 和 to 偏移量都存储在数据库中。为了实现这一点，我通过向读取器分配分区来为每个分区创建一个Kafka使用者，基于先前存储的偏移量，使用者寻求该位置并开始读取。我已关闭自动提交，并且不提交来自使用者的偏移量。对于每个批处理
-
现在，我想存储一个如下所示的文本文件： 1个苹果 香蕉2根 3橙色 4只山猫 5卡布奇诺 以此类推到数据结构中。最好的方法是以某种方式将int映射到字符串，还是我应该制作一个数组列表？当我存储单词本身时，我应该忽略int和任何空格，只保留单词本身。在行中读取时如何忽略int？这是我现在拼凑的代码： } 提前感谢您的帮助！！
-
我有多个Kafka消费者和制作人，主题不同。使用独立应用程序，我想监控Kafka消费者的延迟。 我使用Kafka0.10.0.1，因为Kafka现在存储消费者偏移Kafka本身，所以我怎么能读到相同的。 我能够读取每个分区的主题偏移量。
-
问题内容： 在Windows资源管理器（和Linux gnome）中，为每个文件显示一个缩略图或 图标 。像EXE，图像，视频，txt文件，ini文件，Word文档以及许多其他文件类型一样。现在是我的问题：有没有一种方法可以通过文件获取（最好是较大的）图标。 就像是： 谢谢 问题答案： 似乎没有实现此操作的AWT方法。 如果您使用的是Swing，则可以使用一种方法来获取Swing … … 您还可以
-
本文向大家介绍Kafka 的消费者如何消费数据相关面试题，主要包含被问及Kafka 的消费者如何消费数据时的应答技巧和注意事项，需要的朋友参考一下 消费者每次消费数据的时候，消费者都会记录消费的物理偏移量（offset）的位置 等到下次消费时，他会接着上次位置继续消费