vertx3-kafka:使用Kafka 0.8.2的Vert.x 3的Kafka模块

时间:2021-05-04 06:33:22
【文件属性】:
文件名称:vertx3-kafka:使用Kafka 0.8.2的Vert.x 3的Kafka模块
文件大小:69KB
文件格式:ZIP
更新时间:2021-05-04 06:33:22
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()

网友评论