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)