我在哪里可以找到kafka的maven存储库?
我想尝试kafka 0.8(据我所知它已经发布)。 但是我在哪里可以找到kafka maven存储库。
我应该添加哪些额外的存储库URL?
我找到了一些博客
org.apache.kafka kafka_2.8.0 0.8.0-SHA
但它不起作用。 我正在寻找合适的maven依赖。 或者我应该从git中检出它并部署在我们的内部神器中?
UPDATE
自2013年11月起,官方Kafka版本可在公共Maven存储库中找到,2015年3月的最新版本为0.8.2.1
:
org.apache.kafka kafka_2.10 0.8.2.1
如果你已经创建了下面详述的not.released:kafka
artifact,你可以从本地存储库中删除它 。
原始答案
Kafka尚未发布到公共Maven存储库,但您可以使用install-file命令手动将其添加到本地Maven存储库:
mvn install:install-file -Dpackaging=jar -DgroupId=not.released -DartifactId=kafka -Dversion=0.8.0 -Dfile=kafka.jar
上面的命令行需要当前工作目录中的kafka.jar
文件。 安装后,您可以使用它:
not.released kafka 0.8.0
一旦他们发布Kafka,您只需更改POM中的依赖项,并从本地存储库中删除/卸载此文件。
截至2013年12月,Kafka 0.8 Final已发布,可根据以下定义提供:
org.apache.kafka kafka_2.10 0.8.0
org.apache.kafka kafka_2.9.2 0.8.0-beta1
尽管已经回答了这个问题,但我认为未来的读者可能会从一个开箱即用的完整简单示例中受益。 我把这个放在一起> https://github.com/buildlackey/cep
和操作一样,我一直在努力寻找一个Maven pom.xml配方,这个配方允许我从公共Maven存储库中提取正式版Kafka。 我确实设法使我的示例工作,但是现在我不得不破解我的依赖项,以便我使用的Kafka版本从storm-kafka集成项目的正在进行的版本中提取。 我担心下面的’wip’版本将被弃用。 然后这个项目将失去其依赖性,无法正确构建。 此外,在任何情况下,我真的不应该为这个简单的Kafka示例引入风暴。
风暴 风暴 0.9.0-wip17 风暴 风暴核心 0.9.0-wip17 风暴 风暴卡夫卡 0.9.0-wip16a-scala292
如果有人可以通过Maven为我提供“正确方法”的补丁,我会相应地更新我的项目……希望它能成为其他初级Kafka开发人员的有用资源。
只需访问http://mvnrepository.com/artifact/org.apache.kafka并从列表中选择与您的版本匹配的kafka存储库。
你可以在这里找到所有的realease版本:
http://search.maven.org/#search%7Cga%7C1%7Cg%3A%22org.apache.kafka%22
这是另一条线索:
com.sksamuel.kafka kafka_2.10 0.8.0-beta1
- java.lang.IllegalArgumentException:尚未正确配置Jetty ALPN / NPN
- Kafka使用者 – 消费者进程和线程与主题分区的关系是什么
- kafka KStream – 采用n秒计数的拓扑
- kafka-connect错误:无法找到或加载主类
- 如何动态地将主题传递给kafka监听器?
- Kafka 0.8.2.2 – 无法发布消息
- KafkaProducer未成功将消息发送到队列中
- 是否可以在Kafka 0.8.2中为现有主题添加分区
- Apache Kafka和Avro:org.apache.avro.generic.GenericData $ Record无法强制转换为com.harmeetsingh13.java.Customer