《apache》专题

我刚刚开始研究apache camel（使用蓝图路线），我已经被卡住了。 我需要处理一组不同格式的csv文件。我有5个文件，foo_X_X指定csv文件的类型，文件有日期戳。这些文件可能很大，所以一旦写入所有文件，就会写入一个“完成”文件。完成的文件名为foo_trigger_20160110.csv. 我在文件中看到了doneFileName选项，但它只支持静态名称（我在文件名中有一个日期），或

我不知道我在这里做错了什么。我尝试了各种方法，包括绝对路径、相对路径、启用日志记录（这似乎也不起作用）、使用Main、使用DefaultCamelContext、添加threadsleep，但我无法让camel将文件从一个文件夹移动到另一个文件夹。 这是我的代码： 有人能发现上面的问题吗？ 谢谢

我正在尝试重新排序在Apache Camel之上编写的应用程序摄取文件的顺序。文件需要按设定的顺序处理，如果应用程序没有按顺序处理文件，则文件中数据的各种聚合和其他处理将失败。为了保护应用程序，我尝试使用重新排序器EIP来确保文件按顺序处理。但是我发现重新排序器似乎会导致文件在下游组件通过交换之前被移动到. camel目录中。 我写了一个简单的例子来说明这个问题： 当测试尝试写入输出文件时，会引发

我正在尝试从Spark官方网站运行Spark Streaming示例 这些是我在pom文件中使用的依赖项： 这是我的Java代码： 当我尝试从Eclipse运行它时，我遇到以下异常： 我从我的IDE（eclipse）运行它。我是否必须创建并将JAR部署到火花中以使其运行。如果有人知道这个异常，请分享您的经验。提前谢谢

我尝试使用Apache Camel（版本2.25.3)反应流和Spring Boot来读取一个大型csv文件，并使用Bindy解封这些行。这是“工作”，因为应用程序运行并检测文件，但我只看到流中文件的第一行。它似乎与Bindy相关，因为如果我从等式中去掉解组，我就可以在流中返回csv文件的所有行。我已经简化了这个问题，在这里演示了SO。我正在使用Spring Webflux来公开结果发布者。 所以

在Spring云网站(https://spring.io/projects/spring-cloud-stream)，列出了要使用的活页夹选项。我们有阿帕奇Kafka和Kafka流选项。 他们之间有什么区别

我正在研究Apache Kafka。我想知道哪一个更好：Kafka或ActiveMQ。这两种技术的主要区别是什么？我想在Spring MVC中实现Kafka。

这是我的链接 url正在重写，但页面未运行。。。这是一个错误 未找到 请求的URL/domin。在此服务器上找不到com/new。 此外，尝试使用ErrorDocument处理请求时遇到404 Not Found错误。 域中的Apache服务器。com端口80

我有Laravel项目，可以运行它 我正在目录中执行此命令。之后，我可以看到网站上http://localhost:8000虽然速度很慢，但可以导航。 现在我正在配置apache服务的同一个地方： 不是，我将应用程序指向的不是项目的根目录，而是目录。这使我能够打开该网站的主页，但单击任何链接都会导致错误404。 如果我发球 对于Apache，我根本看不到主页，说403禁止。这可能是因为此目录没有。

我有一个运行Ubuntu 14.04的DigitalOcean服务器。我将它用作我的web开发项目的主机。现在我想开始在我的一个项目中使用Laravel，但我有一个问题。 在Ubuntu的/var/www/html文件夹中，我创建了一个文件夹，比如说，“project”。在这个文件夹中，我使用本教程安装了Laravel。现在一切都设置好了，我想运行Laravel，这样我就可以测试它并开始开发它。当

但是对于事件源，您很可能希望读取给定实体/聚合ID的事件。当然，您可以使用分区，但这似乎滥用了这个概念，而且很难实际添加新实体，因为分区计数更多的是静态的，即使您可以更改它。有什么明智的解决办法吗？Apache Kafka文档本身只简单地提到了事件来源。

我见过（旧？），我一直在考虑使用压缩键，但是对于kafka来说，是否有一个简单的选项可以永远删除消息？ 或者最好的选择是给保留期一个可笑的高值？

是否可以在Apache Flink中使用已经成批训练的模型对dataStream进行预测？ 支持向量机的预测功能需要一个数据集作为输入，而不需要一个数据集。 不幸的是，我不知道如何使用FlatpMap/Map函数使其工作。 我是这样训练SVM模型的： val svm2=SVM（） svm2.setseed(1) svm2.fit（trainLV） val testVD=testlv.map(lv=

我对阿帕奇Flink是新手。我想创建一个DataStream，并向它提供来自另一个系统的值。 我找到了如何添加“SourceFunctions”的示例，在该函数中，我必须等待来自源代码的值，并通过调用CTX.Collect将这些值发布到Flink，然后再次等待，这就是轮询。 这能做到吗？否则，我必须在SourceFunction中执行连接和回调，然后用sleep做一个循环，但我不想这样做... 我