apoorvmittal10 opened a new pull request, #22780: URL: https://github.com/apache/kafka/pull/22780
The PR integrates async processing in DelayedShareFetch which ll help move all the remote fetches out of DelayedShareFetch in future. The DelayedShareFetch is too complex today and shall be simplified by moving the code to read data out of DelayedShareFetch. In subsequent PR more tests will be added for this change. Tested with perf-test: ``` bin/kafka-share-consumer-perf-test.sh --bootstrap-server localhost:9092 --topic test-topic-1 --messages 100000000 --timeout 300000 --group share-group-1 --threads 10 2026-07-07 20:22:00:959, 2026-07-07 20:22:01:960, 83.4237, 2.6258, 305928.0719, 9719560, 1001 for share consumer 1 2026-07-07 20:22:00:960, 2026-07-07 20:22:01:960, 83.2087, 2.6367, 307197.0000, 9694514, 1000 for share consumer 2 2026-07-07 20:22:00:961, 2026-07-07 20:22:01:961, 83.2831, 2.6202, 305271.0000, 9703189, 1000 for share consumer 4 2026-07-07 20:22:00:959, 2026-07-07 20:22:01:962, 83.4402, 2.6370, 307238.2851, 9721486, 1003 for share consumer 8 2026-07-07 20:22:00:961, 2026-07-07 20:22:01:962, 83.4071, 2.6423, 307852.1479, 9717634, 1001 for share consumer 6 2026-07-07 20:22:00:962, 2026-07-07 20:22:01:963, 83.5146, 2.6341, 306890.1099, 9730153, 1001 for share consumer 7 2026-07-07 20:22:00:963, 2026-07-07 20:22:01:963, 83.4980, 2.6367, 307197.0000, 9728227, 1000 for share consumer 10 2026-07-07 20:22:00:962, 2026-07-07 20:22:01:963, 83.3409, 2.6423, 307852.1479, 9709920, 1001 for share consumer 5 2026-07-07 20:22:00:964, 2026-07-07 20:22:01:964, 83.3906, 2.6119, 304308.0000, 9715708, 1000 for share consumer 9 2026-07-07 20:21:12:236, 2026-07-07 20:22:02:329, 858.3300, 17.1347, 1996340.6264, 100002691, 50093 -- 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]
