squah-confluent opened a new pull request, #20780: URL: https://github.com/apache/kafka/pull/20780
Add support for an adaptive batch linger time in the group and share coordinators. When an adaptive batch linger time is enabled, we no longer create a timer to flush the current batch. Instead, we append a flush operation at the end of the event queue so that any currently queued operations are naturally collected into the batch. To avoid double flushing from hitting the maximum batch size or transactional writes, we number batches with an epoch to check whether the batch has already been flushed. The group.coordinator.append.linger.ms and share.coordinator.append.linger.ms configs are extended to allow -1, to specify an adaptive append linger time. The default for these configs is also updated to -1. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
