文件名称：vertx3-kafka:使用Kafka 0.8.2的Vert.x 3的Kafka模块
文件大小：69KB
文件格式：ZIP
更新时间：2024-05-24 00:20:02
Java
这是我的一个小游戏项目，用于测试Kafka与Vert.x的集成。 它绝不是完整的，并且缺少几个领域（尤其是处理多个消费者）。 建造 ./gradlew干净的构建publishToMavenLocal Vert.x 3 Kafka模块 该模块基于Vert.x 3和Kafka 0.8.2。 KafkaHighLevelConsumerVerticle 一个基于的。 KafkaSimpleConsumerVerticle 基于的的。 主要区别在于可以调整读数偏移。 目前，只能阅读而不是提交。 API的这一部分仍然存在一些问题，这使得使用Java-API进行提交变得不可能。 问题解决后（或他们更新其文档），我将立即更新此模块。 在生产者身上 现在，默认情况下，生产者API是异步的，并且易于使用。 如果您需要有关如何在Vert.x中使用它的示例，请查看我用于测试的KafkaProducerV
【文件预览】：
vertx3-kafka-master
----.gitignore(315B)
----build.gradle(2KB)
----src()
--------resources()
--------main()
--------test()
----.travis.yml(34B)
----gradlew(5KB)
----README.md(2KB)
----gradlew.bat(2KB)
----gradle()
--------wrapper()