10
推荐
9.7k
浏览
kafka客户端 - java
半兽人
发布于6年前
说明此客户端是我很早之前封装的，支持`spring`，已经在生产运行8年有余，代码用于学习交流，也可用于生产。描述：- 生产者是同步提交，安全性最高- 消费者是手动提交offset，阻塞式消费，极端情况下，消息最多丢失一条。性能并非最优，但安全健壮性最高。...
半兽人
发布于6年前98
推荐
14k
浏览
kafka通过开始和结束时间，重新消费消息 - java
项目说明通过传入开始和结束时间戳，重新消费kafka历史消息。```public static void main(String[] args) { String startTime = "2018-08-14 21:19:09"; // 开始时间 String endTi...
