从文档中可以看出，这是代理配置，但是细节很少。
1）将其设置为不确定的正确方法是什么？如果这样做，我仍然能够手动删除使用者组及其关联的偏移量吗？
2）我可以将单个消费者群体设置为具有不同的保留率吗？
3）如何查看全局或特定消费者群体的保留率？即使我之前没有设置此功能，我也可以查看并获得一个号码吗？
1）卡夫卡文档提及，对于有效的值offsets.retention.minutes是
[1，...]
这意味着您无法设置，offsets.retention.minutes=-1但可以将其设置为相当大的整数，以便长时间保留偏移量。
2）我假设您正在询问是否可以offsets.retention.minutes在主题级别设置不同的值；据我所知，这是不可能的。您只能在代理级别（即在server.properties文件内部）修改此配置。
编辑：恐怕您不能避免滚动重启，因为您不能offsets.retention.minutes使用进行更改kafka-configs.sh；
> bin/kafka-configs.sh --zookeeper localhost:2181 --entity-type brokers --entity-name 0 --alter --add-config offsets.retention.minutes=200800
Error while executing config command requirement failed: Unknown Dynamic Configuration 'retention.minutes'.
java.lang.IllegalArgumentException: requirement failed: Unknown Dynamic Configuration 'retention.minutes'.
at scala.Predef$.require(Predef.scala:224)
at kafka.server.DynamicConfig$$anonfun$kafka$server$DynamicConfig$$validate$1.apply(DynamicConfig.scala:101)
at kafka.server.DynamicConfig$$anonfun$kafka$server$DynamicConfig$$validate$1.apply(DynamicConfig.scala:100)
at scala.collection.Iterator$class.foreach(Iterator.scala:893)
at scala.collection.AbstractIterator.foreach(Iterator.scala:1336)
at kafka.server.DynamicConfig$.kafka$server$DynamicConfig$$validate(DynamicConfig.scala:100)
at kafka.server.DynamicConfig$Broker$.validate(DynamicConfig.scala:59)
at kafka.admin.AdminUtils$.changeBrokerConfig(AdminUtils.scala:555)
at kafka.admin.ConfigCommand$.alterConfig(ConfigCommand.scala:105)
at kafka.admin.ConfigCommand$.main(ConfigCommand.scala:68)
at kafka.admin.ConfigCommand.main(ConfigCommand.scala)
3）由于这是代理级别的配置，因此您可以查看server.properties文件中的值或代理日志文件中的值。例如，
grep offsets.retention.minutes /path/to/your/kafka-broker.log
请注意，即使您尚未配置offsets.retention.minutes，其值也会默认为10080。
本文收集自互联网，转载请注明来源。
如有侵权，请联系 [email protected] 删除。
我来说两句