kafka客户端 - java

半兽人 发表于: 2018-07-28   最后更新时间: 2021-07-20 09:48:51  
{{totalSubscript}} 订阅,7315 游览

说明

此客户端是我很早之前封装的,支持spring,已经在生产运行5年有余,代码仅用于学习交流。

描述:

  • 生产者是同步提交,安全性最高
  • 消费者是手动提交offset,阻塞式消费,极端情况下,消息最多丢失一条。

性能并非最优,但安全健壮性最高。



您需要解锁本帖隐藏内容请: 点击这里
本帖隐藏的内容



無名 5月前

博主代码功底深厚啊!

BLue 6月前

博主,这是什么群,是qq群吗

半兽人 -> BLue 6月前

是的

Src 9月前

5年之前的代码; 我看客户端版本还是1.0.0的
请问一下作者有更新吗?

半兽人 -> Src 9月前

kafka客户端变化不大,可自行升级程序里的版本对应自己搭建的kafka集群版本。

Src -> 半兽人 9月前

主要是 现在不是有spring-kafka吗?
是否还需要自己写这个客户端

半兽人 -> Src 9月前

嗯 现在我们生产一直在用,可控,学习交流。

1年前

非常好。。。。。。。。。。。。

找不到想要的答案?

我要提问
提问