Details
-
Task
-
Status: Open
-
Major
-
Resolution: Unresolved
-
None
-
None
-
None
Description
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).
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.