最简单的例子. 一个独立消费者(不隶属于任何群组) 重启. 并且消费者代码中没有设置 offset.
我想默认从上一次消费的地点继续消费. 有没有办法实现?
kafka 是如何认识这个独立的消费者? 群组我知道, 是由 group name 来标识. 但是独立消费者我没想明白有什么办法. kafka 权威指南中也没有找到相关的描述.
似乎 kafka 消费者使用群组是一个很普遍的做法.
kafka 新手. 轻喷.
This topic created in 1367 days ago, the information mentioned may be changed or developed.
 |
1
lixen9 Sep 9, 2022
只能自己维护 offset 了
|
 |
2
chaleaochexist OP @lixen9 其实我想问的是 1500 条/秒 是否是一个合理的数据
百万级的都是因为 用集群实现的是吗? |
|
3
chaleaochexist OP @lixen9 发错了不好意思...
|
Select Language