返回到文章

采纳

编辑于 4年前

kafka与kubernetes做任务分发groupid名字如何固定

kafka

大佬,我们用kafka做任务分发,任意一个api收到request,发到kafka中,k8s中多个instance订阅这个topic,处理request.所以需要不同的group Id订阅,最简单的方法就是用key+UUID,但这样会导致测试重启太多的时候,group id暴增 ,不便管理,所以想问问:

  1. 有没有方法,自动产生固定的groupId,比如k8s中10个instance,起来后自动得到groupId0-10.

  2. 我也知道 kafka会自动删除 很久不用的groupId, 相关参数在哪?可以更快的删除这个groupId.