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

一如乞人不需要形象 发表于: 2021-01-14   最后更新时间: 2021-01-14 17:47:31   960 游览

大佬，我们用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.

kafka
发表于 2021-01-14
一如乞人不需要形象
添加评论

1、kubernetes的StatefulSet就是固定的名字，使用它就可以了。
2、不行，现在存储在一个叫__consumer_offsets的topic里，跟log清理一样的流程。

回复
回答于 3年前
半兽人

好的，谢谢

0 0 回复
你的答案

查看kafka相关的其他问题或提一个您自己的问题。
提问

找不到想要的答案？提一个您自己的问题。