Kafka风暴喷口lein或mvn

cdmah0mi 于 2021-06-07 发布在 Kafka

关注(0)|答案(2)|浏览(262)

我是maven的新手，我试图运行strom kafka testtopology spout，但是storm kafka contrib中的storm kafka spout下没有提供pom文件。我用了莱恩，但也没用。我也试着自己用leinpom做一个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\u 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”，架构：“amd64”，系列：“unix”
我应该如何运行testtopology.java？
我得到一个编译错误：
[错误]无法执行goal org.apache.maven。plugins:maven-compiler-plugin：2.0.2:在项目storm kafka上编译（默认编译）：编译失败：编译失败：[error]desktop/storm contrib master/storm kafka/src/jvm/storm/kafka/trident/staticbrokerreader.java:[13，7] -source 1.3[error]中不支持泛型（使用-source 5或更高版本来启用泛型）[error]map brokers=new hashmap（）[错误]

apache-kafka apache-storm maven-3

来源：https://stackoverflow.com/questions/13259368/kafka-storm-spout-lein-or-mvn

2条答案

按热度按时间

n9vozmp41#

将m2-pom.xml重命名为pom.xml。这将节省时间，因为pom.xml是默认名称。
使用eclipsewithm2e插件来可视化您的依赖关系并检查状态。
事情已经整理好了。我在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

赞(0）回复(0）举报 2021-06-07

4uqofj5v2#

我经历了一些悲伤让风暴和Kafka融合在一起。这些都是快速发展和相对年轻的项目，所以很难找到工作的例子来启动您的开发。
为了帮助其他开发人员（希望其他人也能提供有用的示例，我也可以使用），我启动了一个github项目来存放与storm/kafka（和esper）开发相关的代码片段。
欢迎您在这里查看>https://github.com/buildlackey/cep
（点击storm+kafka目录中的一个示例程序，它可以让您启动并运行）。

赞(0）回复(0）举报 2021-06-07

我来回答

Kafka风暴喷口lein或mvn

2条答案

相关问题

热门标签

最新问答