Nir Barel created KAFKA-7782:
--------------------------------
Summary: cleanup policy for offsets topic should be configurable
Key: KAFKA-7782
URL: https://issues.apache.org/jira/browse/KAFKA-7782
Project: Kafka
Issue Type: Improvement
Components: core
Affects Versions: 2.1.0
Reporter: Nir Barel
Hi,
For offsets topic there is no option to change the log cleanup policy from
compact to delete because it is set hard-coded in code here:
[https://github.com/apache/kafka/blob/trunk/core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala#L68]
The only way to override it is to alter the topic at runtime which required to
check the settings and set it after every restart of Kafka.
I am suggesting to configure it via properties with a default value of "compact"
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)