Jeff Kim created KAFKA-15587:
--------------------------------

             Summary: Limit the number of records per batch in 
GroupCoordinatorShard#cleanupGroupMetadata
                 Key: KAFKA-15587
                 URL: https://issues.apache.org/jira/browse/KAFKA-15587
             Project: Kafka
          Issue Type: Task
            Reporter: Jeff Kim


The existing group/offset expiration may generate an unbounded number of 
records. This also applies to the new coordinator 
([https://github.com/apache/kafka/pull/14467).|https://github.com/apache/kafka/pull/14467)]

 

We should limit the number of records per batch. One caveat is that other API 
results assume their records are appended atomically, so we need to keep this 
in mind if we implement the change in CoordinatorPartitionWriter#append. 



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to