{"payload":{"feedbackUrl":"https://github.com/orgs/community/discussions/53140","repo":{"id":2211243,"defaultBranch":"trunk","name":"kafka","ownerLogin":"apache","currentUserCanPush":false,"isFork":false,"isEmpty":false,"createdAt":"2011-08-15T18:06:16.000Z","ownerAvatar":"https://avatars.githubusercontent.com/u/47359?v=4","public":true,"private":false,"isOrgOwned":true},"refInfo":{"name":"","listCacheKey":"v0:1726788246.0","currentOid":""},"activityList":{"items":[{"before":"57013061c159d235f36d95ad0130e058832c26ef","after":"3783385dc1cc27246cf09ec791e4b43f577a26ea","ref":"refs/heads/trunk","pushedAt":"2024-09-19T23:39:13.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"mumrah","name":"David Arthur","path":"/mumrah","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/55116?s=80&v=4"},"commit":{"message":"KAFKA-17542: Use actions/labeler for automatic PR labeling (#17208)\n\nReviewers: Chia-Ping Tsai , David Arthur ","shortMessageHtmlLink":"KAFKA-17542: Use actions/labeler for automatic PR labeling (#17208)"}},{"before":null,"after":"a83ff3d0847c0c89bbb880bd8a1777d0134938ad","ref":"refs/heads/develocity-build-cache","pushedAt":"2024-09-19T23:24:06.000Z","pushType":"branch_creation","commitsCount":0,"pusher":{"login":"mumrah","name":"David Arthur","path":"/mumrah","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/55116?s=80&v=4"},"commit":{"message":"try writing to the develocity build cache","shortMessageHtmlLink":"try writing to the develocity build cache"}},{"before":"e3983c2a442b86db3d0d7ba880437c3a36aa5373","after":"57013061c159d235f36d95ad0130e058832c26ef","ref":"refs/heads/trunk","pushedAt":"2024-09-19T21:07:31.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"mumrah","name":"David Arthur","path":"/mumrah","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/55116?s=80&v=4"},"commit":{"message":"MINOR Fix CI workflow for push event (#17239)\n\nOn trunk, our CI runs in response to \"push\" events. The change in #17227 causes the workflow template to be invalid, which prevents the build from starting. This patch fixes that by defaulting to `false`\r\n\r\nReviewers: Justine Olshan ","shortMessageHtmlLink":"MINOR Fix CI workflow for push event (#17239)"}},{"before":"8569cf102b93f23e2536a6c8659125f6e8b86a8d","after":"e3983c2a442b86db3d0d7ba880437c3a36aa5373","ref":"refs/heads/trunk","pushedAt":"2024-09-19T18:13:07.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"mumrah","name":"David Arthur","path":"/mumrah","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/55116?s=80&v=4"},"commit":{"message":"MINOR Fix is-public-fork input type (#17227)\n\nFix the CI workflow to treat the `is-public-fork` input as a string. \r\n\r\nAlso add some docs on composite actions.\r\n\r\nReviewers: Chia-Ping Tsai ","shortMessageHtmlLink":"MINOR Fix is-public-fork input type (#17227)"}},{"before":"ef567bcc3fe262455b11707818dc6c5b7f7b7e21","after":"8569cf102b93f23e2536a6c8659125f6e8b86a8d","ref":"refs/heads/trunk","pushedAt":"2024-09-19T17:14:58.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"chia7712","name":"Chia-Ping Tsai","path":"/chia7712","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/6234750?s=80&v=4"},"commit":{"message":"KAFKA-17356 add integration test for KAFKA-17310 (#17211)\n\nReviewers: Chia-Ping Tsai ","shortMessageHtmlLink":"KAFKA-17356 add integration test for KAFKA-17310 (#17211)"}},{"before":"e90b24600270424c4b3184cc67a8f5c43438a47f","after":"ef567bcc3fe262455b11707818dc6c5b7f7b7e21","ref":"refs/heads/trunk","pushedAt":"2024-09-19T16:50:07.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"chia7712","name":"Chia-Ping Tsai","path":"/chia7712","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/6234750?s=80&v=4"},"commit":{"message":"MINOR: Group the junit parser console logs (#17229)\n\nUse ::group:: feature of GitHub Actions to hide some of the verbose output from Parse JUnit Tests step.\r\n\r\nReviewers: Chia-Ping Tsai ","shortMessageHtmlLink":"MINOR: Group the junit parser console logs (#17229)"}},{"before":"14c45bed5a1046b65179935188e6205dcfdf6f98","after":"e90b24600270424c4b3184cc67a8f5c43438a47f","ref":"refs/heads/trunk","pushedAt":"2024-09-19T16:00:36.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"chia7712","name":"Chia-Ping Tsai","path":"/chia7712","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/6234750?s=80&v=4"},"commit":{"message":"KAFKA-17555 uncomment all checks of testCommonNameLoggingTrustManagerMixValidAndInvalidCertificates (#17220)\n\nReviewers: TengYao Chi , Chia-Ping Tsai ","shortMessageHtmlLink":"KAFKA-17555 uncomment all checks of testCommonNameLoggingTrustManager…"}},{"before":"31d395163e55487c6f2025a2ed08cfe3ad1c9cdb","after":"14c45bed5a1046b65179935188e6205dcfdf6f98","ref":"refs/heads/trunk","pushedAt":"2024-09-19T14:52:58.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"clolov","name":"Christo Lolov","path":"/clolov","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/20223851?s=80&v=4"},"commit":{"message":"KAFKA-17579: Dynamic LogCleaner configurations are picked up on restart\n\nReviewers: Christo Lolov ","shortMessageHtmlLink":"KAFKA-17579: Dynamic LogCleaner configurations are picked up on restart"}},{"before":"8f5cf9968f3005a4ed1acf27fe57456691aac5eb","after":"31d395163e55487c6f2025a2ed08cfe3ad1c9cdb","ref":"refs/heads/trunk","pushedAt":"2024-09-19T07:17:25.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"chia7712","name":"Chia-Ping Tsai","path":"/chia7712","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/6234750?s=80&v=4"},"commit":{"message":"KAFKA-17553 Fix shutdown race condition in StreamThreadTest (#17191)\n\nReviewers: Chia-Ping Tsai ","shortMessageHtmlLink":"KAFKA-17553 Fix shutdown race condition in StreamThreadTest (#17191)"}},{"before":"09e3c12057b1e15ad2a9fb85af452fd3c3dc87e1","after":"8f5cf9968f3005a4ed1acf27fe57456691aac5eb","ref":"refs/heads/trunk","pushedAt":"2024-09-19T06:58:04.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"chia7712","name":"Chia-Ping Tsai","path":"/chia7712","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/6234750?s=80&v=4"},"commit":{"message":"KAFKA-17515 Fix flaky RestoreIntegrationTest.shouldInvokeUserDefinedGlobalStateRestoreListener (#17187)\n\nFound two issues in the flaky tests: (Put the log analysis under Jira comments.)\r\n\r\n1) The error \"java.nio.file.DirectoryNotEmptyException\" occurs if the flush() of kafkaStreams.close() and purgeLocalStreamsState() are triggered in the same time. (The current timeout is 5 sec, which is too short since the CI is unstable and slow).\r\n2) Racing issue: Task to-be restored in ks-1 are rebalanced to ks-2 before entering active restoring state. So no onRestoreSuspend() was triggered.\r\n\r\nTo solve the issues:\r\n1) Remove the timeout in kafkaStreams.close()\r\n2) Ensure all tasks in ks-1 are active restoring before start second KafkaStreams(ks-2)\r\n\r\nReviewers: Chia-Ping Tsai ","shortMessageHtmlLink":"KAFKA-17515 Fix flaky RestoreIntegrationTest.shouldInvokeUserDefinedG…"}},{"before":"c141acb6bf88e549de2459e834657439a2bb5be9","after":"83091994a6324c19b29f5802489513a943f13664","ref":"refs/heads/3.9","pushedAt":"2024-09-18T18:47:05.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"cmccabe","name":"Colin Patrick McCabe","path":"/cmccabe","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/1095624?s=80&v=4"},"commit":{"message":"KAFKA-17543: Improve and clarify the error message about generated broker IDs in migration (#17210)\n\nThis PR tries to improve the error message when broker.id is set to -1 and ZK migration is enabled. It is not\r\nneeded to disable the broker.id.generation.enable option. It is sufficient to just not use it (by not setting\r\nthe broker.id to -1).\r\n\r\nReviewers: Chia-Ping Tsai , Luke Chen ","shortMessageHtmlLink":"KAFKA-17543: Improve and clarify the error message about generated br…"}},{"before":"3636afb737dd1baa2b89a82a8ad54a9440099a90","after":"09e3c12057b1e15ad2a9fb85af452fd3c3dc87e1","ref":"refs/heads/trunk","pushedAt":"2024-09-18T18:45:25.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"cmccabe","name":"Colin Patrick McCabe","path":"/cmccabe","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/1095624?s=80&v=4"},"commit":{"message":"KAFKA-17543: Improve and clarify the error message about generated broker IDs in migration (#17210)\n\nThis PR tries to improve the error message when broker.id is set to -1 and ZK migration is enabled. It is not\r\nneeded to disable the broker.id.generation.enable option. It is sufficient to just not use it (by not setting\r\nthe broker.id to -1).\r\n\r\nReviewers: Chia-Ping Tsai , Luke Chen ","shortMessageHtmlLink":"KAFKA-17543: Improve and clarify the error message about generated br…"}},{"before":"389a8d8decc05a4d73ab1dce6f158b2d13398450","after":"c141acb6bf88e549de2459e834657439a2bb5be9","ref":"refs/heads/3.9","pushedAt":"2024-09-18T18:34:24.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"cmccabe","name":"Colin Patrick McCabe","path":"/cmccabe","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/1095624?s=80&v=4"},"commit":{"message":"KAFKA-17048; Update docs for KIP-853 (#17076)\n\nChange the configurations under config/kraft to use controller.quorum.bootstrap.servers instead of controller.quorum.voters. Add comments explaining how to use the older static quorum configuration where appropriate.\n\nIn docs/ops.html, remove the reference to \"tentative timelines for ZooKeeper removal\" and \"Tiered storage is considered as an early access feature\" since they are no longer up-to-date. Add KIP-853 information.\n\nIn docs/quickstart.html, move the ZK instructions to be after the KRaft instructions. Update the KRaft instructions to use KIP-853.\n\nIn docs/security.html, add an explanation of --bootstrap-controller and document controller.quorum.bootstrap.servers instead of controller.quorum.voters.\n\nReviewers: Mickael Maison , Alyssa Huang , Colin P. McCabe ","shortMessageHtmlLink":"KAFKA-17048; Update docs for KIP-853 (#17076)"}},{"before":"aee44efd40f7d9aa55ac1aeb13b3ec0135f600fc","after":"3636afb737dd1baa2b89a82a8ad54a9440099a90","ref":"refs/heads/trunk","pushedAt":"2024-09-18T18:33:47.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"cmccabe","name":"Colin Patrick McCabe","path":"/cmccabe","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/1095624?s=80&v=4"},"commit":{"message":"HOTFIX: add file that was missed from KAFKA-17048 commit","shortMessageHtmlLink":"HOTFIX: add file that was missed from KAFKA-17048 commit"}},{"before":"77e952687bd4cc5f2423f2824ac20cb061c91836","after":"aee44efd40f7d9aa55ac1aeb13b3ec0135f600fc","ref":"refs/heads/trunk","pushedAt":"2024-09-18T18:23:58.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"cmccabe","name":"Colin Patrick McCabe","path":"/cmccabe","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/1095624?s=80&v=4"},"commit":{"message":"KAFKA-17048; Update docs for KIP-853 (#17076)\n\nChange the configurations under config/kraft to use controller.quorum.bootstrap.servers instead of controller.quorum.voters. Add comments explaining how to use the older static quorum configuration where appropriate.\r\n\r\nIn docs/ops.html, remove the reference to \"tentative timelines for ZooKeeper removal\" and \"Tiered storage is considered as an early access feature\" since they are no longer up-to-date. Add KIP-853 information.\r\n\r\nIn docs/quickstart.html, move the ZK instructions to be after the KRaft instructions. Update the KRaft instructions to use KIP-853.\r\n\r\nIn docs/security.html, add an explanation of --bootstrap-controller and document controller.quorum.bootstrap.servers instead of controller.quorum.voters.\r\n\r\nReviewers: Mickael Maison , Alyssa Huang , Colin P. McCabe ","shortMessageHtmlLink":"KAFKA-17048; Update docs for KIP-853 (#17076)"}},{"before":"74bebf6e3dfdc9de6894d656bdbbb28a4c33eda8","after":"77e952687bd4cc5f2423f2824ac20cb061c91836","ref":"refs/heads/trunk","pushedAt":"2024-09-18T16:19:47.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"satishd","name":"Satish Duggana","path":"/satishd","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2577761?s=80&v=4"},"commit":{"message":"KAFKA-17559: Fix the flaky RemoteLogOffsetReader#testTaskQueueFullAndCancelTask (#17214)\n\nReviewers: David Arthur , Satish Duggana , Luke Chen ","shortMessageHtmlLink":"KAFKA-17559: Fix the flaky RemoteLogOffsetReader#testTaskQueueFullAnd…"}},{"before":"6ad68fa038444ad142ec962666353c6e4113a19e","after":null,"ref":"refs/heads/minor-log-pending-members","pushedAt":"2024-09-18T07:34:10.000Z","pushType":"branch_deletion","commitsCount":0,"pusher":{"login":"dajac","name":"David Jacot","path":"/dajac","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/157182?s=80&v=4"}},{"before":"95b734d3c86c06a1599e8559d0ab2f95b442125c","after":"74bebf6e3dfdc9de6894d656bdbbb28a4c33eda8","ref":"refs/heads/trunk","pushedAt":"2024-09-18T07:34:06.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"dajac","name":"David Jacot","path":"/dajac","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/157182?s=80&v=4"},"commit":{"message":"MINOR: Log pending join members (#17219)\n\nI am still chasing KAFKA-17493. I was able to narrow it down to an issue with the pending join members. This patch logs them in order to help me troubleshooting it further. I will revert this change when the issue is root caused.\r\n\r\nReviewers: David Arthur ","shortMessageHtmlLink":"MINOR: Log pending join members (#17219)"}},{"before":null,"after":"6ad68fa038444ad142ec962666353c6e4113a19e","ref":"refs/heads/minor-log-pending-members","pushedAt":"2024-09-18T01:08:59.000Z","pushType":"branch_creation","commitsCount":0,"pusher":{"login":"dajac","name":"David Jacot","path":"/dajac","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/157182?s=80&v=4"},"commit":{"message":"MINOR: Log pending join members","shortMessageHtmlLink":"MINOR: Log pending join members"}},{"before":"f1e7954ad1dd2dc865195cdb796e2b1d518f8b85","after":"95b734d3c86c06a1599e8559d0ab2f95b442125c","ref":"refs/heads/trunk","pushedAt":"2024-09-17T20:56:45.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"chia7712","name":"Chia-Ping Tsai","path":"/chia7712","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/6234750?s=80&v=4"},"commit":{"message":"KAFKA-17472 Speed Up DescribeConsumerGroupTest (#17117)\n\nReviewers: Chia-Ping Tsai ","shortMessageHtmlLink":"KAFKA-17472 Speed Up DescribeConsumerGroupTest (#17117)"}},{"before":"f324ef461f9d9e7fc38324336727e0cc269b95db","after":"389a8d8decc05a4d73ab1dce6f158b2d13398450","ref":"refs/heads/3.9","pushedAt":"2024-09-17T19:05:25.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"cmccabe","name":"Colin Patrick McCabe","path":"/cmccabe","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/1095624?s=80&v=4"},"commit":{"message":"Revert \"KAFKA-16803: Change fork, update ShadowJavaPlugin to 8.1.7 (#16295)\" (#17218)\n\nThis reverts commit 391778b8d737f4af074422ffe61bc494b21e6555.\r\n\r\nUnfortunately that commit re-introduced bug #15127 which prevented the publishing of kafka-clients\r\nartifacts to remote maven. As that bug says:\r\n\r\n The issue triggers only with publishMavenJavaPublicationToMavenRepository due to signing.\r\n Generating signed asc files error out for shadowed release artifacts as the module name\r\n (clients) differs from the artifact name (kafka-clients).\r\n\r\n The fix is basically to explicitly define artifact of shadowJar to signing and publish plugin.\r\n project.shadow.component(mavenJava) previously outputs the name as client--all.jar\r\n though the classifier and archivesBaseName are already defined correctly in :clients and\r\n shadowJar construction.\r\n\r\nReviewers: David Arthur ","shortMessageHtmlLink":"Revert \"KAFKA-16803: Change fork, update ShadowJavaPlugin to 8.1.7 (#…"}},{"before":"aaf3fc05f8e7cb6b8c79f8471f68faa3a994e1e5","after":"f1e7954ad1dd2dc865195cdb796e2b1d518f8b85","ref":"refs/heads/trunk","pushedAt":"2024-09-17T14:37:04.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"cmccabe","name":"Colin Patrick McCabe","path":"/cmccabe","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/1095624?s=80&v=4"},"commit":{"message":"MINOR: update documentation link to 3.9 (#17216)\n\nReviewers: David Arthur ","shortMessageHtmlLink":"MINOR: update documentation link to 3.9 (#17216)"}},{"before":"a1a4389c35026805cdccd5aa1a5b5d1ac5cd5205","after":"f324ef461f9d9e7fc38324336727e0cc269b95db","ref":"refs/heads/3.9","pushedAt":"2024-09-17T14:36:08.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"cmccabe","name":"Colin Patrick McCabe","path":"/cmccabe","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/1095624?s=80&v=4"},"commit":{"message":"MINOR: update documentation link to 3.9 (#17216)\n\nReviewers: David Arthur ","shortMessageHtmlLink":"MINOR: update documentation link to 3.9 (#17216)"}},{"before":"f1c011a8b5c3eb94a9c3f84ea6497b36445bcb5c","after":"aaf3fc05f8e7cb6b8c79f8471f68faa3a994e1e5","ref":"refs/heads/trunk","pushedAt":"2024-09-16T18:49:19.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"mjsax","name":"Matthias J. Sax","path":"/mjsax","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/8959638?s=80&v=4"},"commit":{"message":"MINOR: fix rawtype warning in StandbyTask (#17203)\n\nReviewers: Chia-Ping Tsai ","shortMessageHtmlLink":"MINOR: fix rawtype warning in StandbyTask (#17203)"}},{"before":"21e67b3d21ec17d1fdd8d01a8d5cd9965efa5907","after":"f1c011a8b5c3eb94a9c3f84ea6497b36445bcb5c","ref":"refs/heads/trunk","pushedAt":"2024-09-16T16:37:50.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"chia7712","name":"Chia-Ping Tsai","path":"/chia7712","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/6234750?s=80&v=4"},"commit":{"message":"KAFKA-14482 Move LogLoader to storage module (#17042)\n\nReviewers: Chia-Ping Tsai ","shortMessageHtmlLink":"KAFKA-14482 Move LogLoader to storage module (#17042)"}},{"before":"d0f4d691b592ed2d65c9df413f5d6660df7fc90e","after":"21e67b3d21ec17d1fdd8d01a8d5cd9965efa5907","ref":"refs/heads/trunk","pushedAt":"2024-09-16T16:27:52.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"chia7712","name":"Chia-Ping Tsai","path":"/chia7712","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/6234750?s=80&v=4"},"commit":{"message":"KAFKA-16331 Remove EOSv1 from Kafka Streams integration tests (#17110)\n\nReviewers: Bill Bejeck , Chia-Ping Tsai ","shortMessageHtmlLink":"KAFKA-16331 Remove EOSv1 from Kafka Streams integration tests (#17110)"}},{"before":"ab1eb8d561ca3ac4a1366f866d450d92c3a0144a","after":"d0f4d691b592ed2d65c9df413f5d6660df7fc90e","ref":"refs/heads/trunk","pushedAt":"2024-09-16T12:19:47.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"jlprat","name":"Josep Prat","path":"/jlprat","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/3337739?s=80&v=4"},"commit":{"message":"KAFKA-17322: Document required header versions in Protocol Guide (#16867)\n\nReviewers: Josep Prat ","shortMessageHtmlLink":"KAFKA-17322: Document required header versions in Protocol Guide (#16867"}},{"before":"344d8a60af8ba7e4ae646501494b17b6987a95d3","after":"ab1eb8d561ca3ac4a1366f866d450d92c3a0144a","ref":"refs/heads/trunk","pushedAt":"2024-09-16T10:03:59.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"jlprat","name":"Josep Prat","path":"/jlprat","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/3337739?s=80&v=4"},"commit":{"message":"KAFKA-17494: Document message structure in Protocol Guide (#17122)\n\nReviewers: Josep Prat ","shortMessageHtmlLink":"KAFKA-17494: Document message structure in Protocol Guide (#17122)"}},{"before":"e1f11c67140f995bc22acd1568fcfac593c1ee10","after":"344d8a60af8ba7e4ae646501494b17b6987a95d3","ref":"refs/heads/trunk","pushedAt":"2024-09-15T23:25:06.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"chia7712","name":"Chia-Ping Tsai","path":"/chia7712","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/6234750?s=80&v=4"},"commit":{"message":"KAFKA-15859 Make RemoteListOffsets call an async operation (#16602)\n\nThis is the part-2 of the KIP-1075\r\n\r\nTo find the offset for a given timestamp, ListOffsets API is used by the client. When the topic is enabled with remote storage, then we have to fetch the remote indexes such as offset-index and time-index to serve the query. Also, the ListOffsets request can contain the query for multiple topics/partitions.\r\n\r\nThe time taken to read the indexes from remote storage is non-deterministic and the query is handled by the request-handler threads. If there are multiple LIST_OFFSETS queries and most of the request-handler threads are busy in reading the data from remote storage, then the other high-priority requests such as FETCH and PRODUCE might starve and be queued. This can lead to higher latency in producing/consuming messages.\r\n\r\nIn this patch, we have introduced a delayed operation for remote list-offsets call. If the timestamp need to be searched in the remote-storage, then the request-handler threads will pass-on the request to the remote-log-reader threads. And, the request gets handled in asynchronous fashion.\r\n\r\nCovered the patch with unit and integration tests.\r\n\r\nReviewers: Satish Duggana , Luke Chen , Chia-Ping Tsai ","shortMessageHtmlLink":"KAFKA-15859 Make RemoteListOffsets call an async operation (#16602)"}},{"before":"9529bb33d2e70327969ea824307b44f12ec082a1","after":null,"ref":"refs/heads/minor-add-logging-to-maybe-complete-join","pushedAt":"2024-09-15T20:18:57.000Z","pushType":"branch_deletion","commitsCount":0,"pusher":{"login":"dajac","name":"David Jacot","path":"/dajac","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/157182?s=80&v=4"}}],"hasNextPage":true,"hasPreviousPage":false,"activityType":"all","actor":null,"timePeriod":"all","sort":"DESC","perPage":30,"cursor":"djE6ks8AAAAEu2g5-QA","startCursor":null,"endCursor":null}},"title":"Activity · apache/kafka"}