【文件属性】:
文件名称:vertx-kafka-service:Vert.x服务在Kafka和Vert.x事件总线之间架起桥梁
文件大小:72KB
文件格式:ZIP
更新时间:2021-04-29 08:40:52
Java
Vert.x Kafka服务
兼容性
Java 8+
Vert.x 3.1.0> =
Vert.x版本
卡夫卡版
图书馆版本
3.1.0
0.8.x
1.0.0
3.3.0
0.8.x
1.1.0
3.3.3
0.10.1
1.2.0
3.5.1
1.1.0
1.2.12
Vert.x Kafka消费者
此服务使您可以将消息从Kafka桥接到Vert.x事件总线。 它允许异步消息处理,同时仍保持正确的Kafka偏移量。
它实现了“至少一次”的语义,处理程序必须确认所有事件总线消息,以便提交当前的Kafka偏移量。 这意味着事件总线上的处理程序必须能够处理消息重播。
有两种使用服务的方法,一种是将strictOdering设置为true ,这是默认设置,它严格按照到达顺序将消息中继到Vert.x EventBus并等待ACK。 另一种是将strictOrderi