我的需求是每个消费者节点都需要接收到kafka消息,所以每个节点的groupid都写成不一样的值,但是这样的话每次重启服务,都会生成一个新的groupid,相当于原来的groupid不再消费消息了。 这样节点很多的话每次重启都会创建很多group的话,对于kafka服务有没有什么影响?group创建后很久没消费的话,会不会被清理掉? 我看资料上说位移提交的放在__consumeroffsets topic里的,那么这个topic会不会也和其他topic一样,默认清理7天前的数据呢?
没有影响,是的,默认7天清理。
组很久没用的话自己就会清理吗?
会的。
好的 谢谢谢谢
你的答案