1

我是 maven 的新手，我试图运行 strom kafka TestTopology spout，但是在storm-kafka spout 下的storm-kafka contrib 中没有提供pom 文件。我使用了 Lein，它也不起作用。我还尝试使用 lein pom 自己制作一个 pom（并对其进行修改），但它也不起作用。我正在从上到下构建项目：我在storm-conrib-master 中运行mvn，它成功构建了更高级别，但是我如何使用storm starter 中的m2-pom 运行TestTopology.java { 稍作更改} 我使用这个：

mvn -f m2-pom.xml compile exec:java -Dexec.classpathScope=compile -Dexec.mainClass=storm.kafka.TestTopology

我还使用了 project.clj 设置和 lein，它也不起作用，但 lein 不是我的菜。这是 Maven 设置：

Apache Maven 3.0.4 Maven 主页：/usr/share/maven Java 版本：

1.6.0_33，供应商：Sun Microsystems Inc.

Java home: /usr/lib/jvm/java-6-sun-1.6.0.33/jre Default locale: en_US, platform

编码：UTF-8 操作系统名称：“linux”，版本：“3.2.0-32-generic”，arch：“amd64”，家族：“unix”

我应该如何运行 TestTopology.java？

我收到编译错误：

[错误] 无法执行目标 org.apache.maven.plugins:maven-compiler-plugin:2.0.2:compile (default-compile) on projectstorm-kafka: 编译失败：编译失败：[错误] Desktop/storm- contrib-master/storm-kafka/src/jvm/storm/kafka/trident/StaticBrokerReader.java:[13,7] -source 1.3 [错误] 不支持泛型（使用 -source 5 或更高版本来启用泛型）[错误] 地图代理 = new HashMap(); [错误]

4

2 回答 2

1
  1. 将 m2-pom.xml 重命名为 pom.xml。这将节省时间，因为 pom.xml 是默认名称。
  2. 使用带有m2e 插件的 Eclipse来可视化您的依赖关系并检查状态。
  3. 东西已经编译好了。我在clojars.org找到了它们

下面是我玩的 pom.xml：

<properties>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<repositories>
    <repository>
        <id>github-releases</id>
        <url>http://oss.sonatype.org/content/repositories/github-releases/</url>
    </repository>
    <repository>
        <id>clojars.org</id>
        <url>http://clojars.org/repo</url>
    </repository>
    <repository>
        <id>twitter4j</id>
        <url>http://twitter4j.org/maven2</url>
    </repository>
</repositories>

<dependencies>
    <dependency>
        <groupId>storm</groupId>
        <artifactId>storm-lib</artifactId>
        <version>0.9.0-wip9</version>
    </dependency>


    <dependency>
      <groupId>storm</groupId>
      <artifactId>storm-kafka</artifactId>
      <version>0.9.0-wip6-scala292-multischeme</version>
    </dependency>

</dependencies>

在 Storm wiki 上阅读 Maven 页面： https ://github.com/nathanmarz/storm/wiki/Maven

于 2012-12-20T09:26:29.257 回答
0

我经历了一些悲伤的风暴和卡夫卡的整合。这些都是快速发展且相对年轻的项目，因此很难获得工作示例来快速开始您的开发。

为了帮助其他开发人员（并希望其他人贡献我可以使用的有用示例），我启动了一个 github 项目来存放与 Storm/Kafka（和 Esper）开发相关的代码片段。

欢迎您在这里查看> https://github.com/buildlackey/cep

（单击storm+kafka 目录可以找到一个可以帮助你启动并运行的示例程序）。

于 2013-10-25T21:54:46.357 回答