大佬,我们用kafka做任务分发,任意一个api收到request,发到kafka中,k8s中多个instance订阅这个topic,处理request.所以需要不同的group Id订阅,最简单的方法就是用key+UUID,但这样会导致测试重启太多的时候,group id暴增 ,不便管理,所以想问问:
有没有方法,自动产生固定的groupId,比如k8s中10个instance,起来后自动得到groupId0-10.
我也知道 kafka会自动删除 很久不用的groupId, 相关参数在哪?可以更快的删除这个groupId.
1、kubernetes的StatefulSet就是固定的名字,使用它就可以了。
2、不行,现在存储在一个叫
__consumer_offsets
的topic里,跟log清理一样的流程。好的,谢谢
你的答案