mirror of https://github.com/apache/kafka.git
When expiring transactionalIds, we group the tombstones together into batches. Currently there is no limit on the size of these batches, which can lead to `MESSAGE_TOO_LARGE` errors when a bunch of transactionalIds need to be expired at the same time. This patch fixes the problem by ensuring that the batch size respects the configured limit. Any transactionalIds which are eligible for expiration and cannot be fit into the batch are postponed until the next periodic check. Reviewers: David Jacot <djacot@confluent.io>, Guozhang Wang <wangguoz@gmail.com> |
||
---|---|---|
.. | ||
src | ||
.gitignore |