Ok, thanks again for the help, and another question, by default we did not set the config item, so does not it take effect with the default situation?
I just searched the code with the configuration key “offset.retention.minutes", but I can get any reference, be changed? Best Regards, Peyton 湖南福米信息科技有限责任公司 Hunan Fumi Financial Technology Co., Ltd. =========================================================== 地址 / Add :湖南省长沙市高新区岳麓西大道588号芯城科技园3栋5F (410000) 5/F, Building 3, Xincheng Science & Technology Park No.588 Yuelu West Ave, Changsha 410000, Hunan, P.R.China 手机 / Cell : (86) 150 2113 9776 邮箱 / Mail : p...@webull.com =========================================================== > 在 2018年8月13日,下午11:52,Vahid S Hashemian <vahidhashem...@us.ibm.com> 写道: > > Hi Peyton, > > Yes, if you'd like to change the value a broker restart is required for the > change to take effect. > > --Vahid > > > > From: "ÅíÅô(Peyton)" <p...@webull.com> > To: Vahid S Hashemian <vahidhashem...@us.ibm.com> > Cc: users@kafka.apache.org, "彭鹏" <p...@webull.com> > Date: 08/13/2018 08:49 AM > Subject: Re: Question how to drop a unused group id? > > > > Hi Vahid, > > Thank you very much for the reply, we use the kafka ver 2.11-0.10.2.1. > > So when I apply the "offset.retention.minutes" to the system that request a > restart to be effected? > > Best Regards, > Peyton > > 湖南福米信息科技有限责任公司 Hunan Fumi Financial Technology Co., Ltd. > =========================================================== > 地址 / Add :湖南省长沙市高新区岳麓西大道588号芯城科技园3栋5F (410000) > 5/F, Building 3, Xincheng Science & Technology Park > No.588 Yuelu West Ave, Changsha 410000, Hunan, P.R.China > 手机 / Cell : (86) 150 2113 9776 > 邮箱 / Mail : p...@webull.com <mailto:p...@webull.com> > =========================================================== > > 在 2018年8月13日,下午11:43,Vahid S Hashemian <vahidhashem...@us.ibm.com > <mailto:vahidhashem...@us.ibm.com>> 写道: > > Hi Peyton, > > What version of Kafka are you using? > Starting from version 1.1.0 there is a DELETE_GROUP API: > https://cwiki.apache.org/confluence/display/KAFKA/KIP-229%3A+DeleteGroups+API > <https://cwiki.apache.org/confluence/display/KAFKA/KIP-229%3A+DeleteGroups+API> > You can also use the consumer group command with `--delete` to delete a group. > > For prior versions, the safest option would be to wait for > `offset.retention.minutes` until all group offsets are expired. > > --Vahid > > > > > From: "ÅíÅô(Peyton)" <p...@webull.com <mailto:p...@webull.com>> > To: users@kafka.apache.org <mailto:users@kafka.apache.org> > Cc: "彭鹏" <p...@webull.com <mailto:p...@webull.com>> > Date: 08/13/2018 08:12 AM > Subject: Question how to drop a unused group id? > > > > Hi kafka team, > > I have an issue about drop the unused group id which is created with the new > consumer api, but I found no way to process it, can you please give mi a hint > how to do it? > > Thank you very much. > > Regards, > Peyton > > 湖南福米信息科技有限责任公司 Hunan Fumi Financial Technology Co., Ltd. > =========================================================== > 地址 / Add :湖南省长沙市高新区岳麓西大道588号芯城科技园3栋5F (410000) > 5/F, Building 3, Xincheng Science & Technology Park > No.588 Yuelu West Ave, Changsha 410000, Hunan, P.R.China > 手机 / Cell : (86) 150 2113 9776 > 邮箱 / Mail : p...@webull.com <mailto:p...@webull.com> > =========================================================== > > > > > >