有 Java 编程相关的问题?

你可以在下面搜索框中键入要查询的问题!

java我在哪里可以找到kafka的maven存储库?

我想试试卡夫卡0.8(据我所知,它已经发布了)。但是我在哪里可以找到卡夫卡·梅文的存储库呢

我应该添加什么额外的存储库url

我发现了一些有

 <dependency>
    <groupId>org.apache.kafka</groupId>
    <artifactId>kafka_2.8.0</artifactId>
    <version>0.8.0-SHA</version>
 </dependency>

但这是行不通的。我正在寻找适当的maven依赖关系。或者我应该从git签出它并部署到我们的内部构件中


共 (6) 个答案

  1. # 1 楼答案

        <dependency>
            <groupId>org.apache.kafka</groupId>
            <artifactId>kafka_2.9.2</artifactId>
            <version>0.8.0-beta1</version>
        </dependency>
    
  2. # 2 楼答案

    更新

    自2013年11月起,卡夫卡官方发行版可在public Maven repository上找到,2015年3月的最新版本为0.8.2.1

    <dependency>
      <groupId>org.apache.kafka</groupId>
      <artifactId>kafka_2.10</artifactId>
      <version>0.8.2.1</version>
    </dependency>
    

    如果您创建了下面详细介绍的not.released:kafka工件,您可以从本地存储库remove it


    原始答案

    Kafka尚未发布到公共Maven存储库中,但您可以使用install-file command手动将其添加到本地Maven存储库中:

    mvn install:install-file -Dpackaging=jar -DgroupId=not.released
        -DartifactId=kafka -Dversion=0.8.0 -Dfile=kafka.jar
    

    上面的命令行需要当前工作目录中的kafka.jar文件。 安装后,您可以将其用于:

    <dependency>
      <groupId>not.released</groupId>
      <artifactId>kafka</artifactId>
      <version>0.8.0</version>
    </dependency>
    

    一旦他们发布了Kafka,你就可以更改POM中的依赖项,并从本地存储库中删除/卸载该文件

  3. # 3 楼答案

    尽管这个问题已经得到了回答,但我认为未来的读者可能会从一个完全简单的开箱即用的例子中受益。我在这里放了一个>; https://github.com/buildlackey/cep

    和o.p.一样,我一直在努力寻找Maven pom。xml配方,允许我从公共Maven存储库中获取卡夫卡的官方版本。我的确成功地让我的例子发挥了作用,但现在我不得不进行黑客攻击 我的依赖项,因此我使用的卡夫卡版本是从正在进行的版本中提取的 风暴卡夫卡整合项目。我担心下面的“wip”版本会被弃用。 那么这个项目就会失去依赖性,无法正确构建。还有,我 在任何情况下,现在都不应该为这个简单的卡夫卡例子引入风暴

    
       
            storm
            storm
            0.9.0-wip17
        
        
            storm
            storm-core
            0.9.0-wip17
        
        
            storm
            storm-kafka
            0.9.0-wip16a-scala292
        
        
    
    
    

    如果有人能为我提供一个补丁,让我用Maven实现这个目标,我会相应地更新我的项目。。。。希望它能为其他卡夫卡初学者提供有用的资源

  4. # 6 楼答案

    截至2013年12月,Kafka 0.8 Final已发布,并按以下定义提供:

    <dependency>
      <groupId>org.apache.kafka</groupId>
      <artifactId>kafka_2.10</artifactId>
      <version>0.8.0</version>
    </dependency>