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)

Reply via email to