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