{"payload":{"feedbackUrl":"https://github.com/orgs/community/discussions/53140","repo":{"id":395914172,"defaultBranch":"trunk","name":"kafka","ownerLogin":"clolov","currentUserCanPush":false,"isFork":true,"isEmpty":false,"createdAt":"2021-08-14T06:27:27.000Z","ownerAvatar":"https://avatars.githubusercontent.com/u/20223851?v=4","public":true,"private":false,"isOrgOwned":false},"refInfo":{"name":"","listCacheKey":"v0:1727439384.0","currentOid":""},"activityList":{"items":[{"before":null,"after":"0885336034f4997c574e3a92ff93baf3fcb3d89e","ref":"refs/heads/remove-extra-partitions","pushedAt":"2024-09-27T12:16:24.000Z","pushType":"branch_creation","commitsCount":0,"pusher":{"login":"clolov","name":"Christo Lolov","path":"/clolov","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/20223851?s=80&v=4"},"commit":{"message":"Initial prototype for removing extraneous partitions at broker startup","shortMessageHtmlLink":"Initial prototype for removing extraneous partitions at broker startup"}},{"before":"aaf3fc05f8e7cb6b8c79f8471f68faa3a994e1e5","after":"d06344382574eec3da917e00e4537e40449f16e2","ref":"refs/heads/trunk","pushedAt":"2024-09-23T09:08:23.000Z","pushType":"push","commitsCount":23,"pusher":{"login":"clolov","name":"Christo Lolov","path":"/clolov","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/20223851?s=80&v=4"},"commit":{"message":"MINOR: fixing JavaDocs and other cleanup (#17207)\n\nReviewers: Chia-Ping Tsai ","shortMessageHtmlLink":"MINOR: fixing JavaDocs and other cleanup (apache#17207)"}},{"before":"344d8a60af8ba7e4ae646501494b17b6987a95d3","after":"aaf3fc05f8e7cb6b8c79f8471f68faa3a994e1e5","ref":"refs/heads/trunk","pushedAt":"2024-09-17T12:35:42.000Z","pushType":"push","commitsCount":5,"pusher":{"login":"clolov","name":"Christo Lolov","path":"/clolov","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/20223851?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 (apache#17203)"}},{"before":"d95e384146e67e475b2e0638f70d6f4a708a01dc","after":"344d8a60af8ba7e4ae646501494b17b6987a95d3","ref":"refs/heads/trunk","pushedAt":"2024-09-16T09:06:44.000Z","pushType":"push","commitsCount":16,"pusher":{"login":"clolov","name":"Christo Lolov","path":"/clolov","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/20223851?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 (apache#16602"}},{"before":"c977bfdd3cda4f7f4d3313d02e151df756872800","after":"d95e384146e67e475b2e0638f70d6f4a708a01dc","ref":"refs/heads/trunk","pushedAt":"2024-09-13T15:16:27.000Z","pushType":"push","commitsCount":132,"pusher":{"login":"clolov","name":"Christo Lolov","path":"/clolov","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/20223851?s=80&v=4"},"commit":{"message":"KAFKA-17508: Adding some guard for fallback deletion logic (#17154)\n\nIn KAFKA-16424, we added a fallback logic to delete the logs, but the file has no parent. It'd be better we have some guard from it.\r\n\r\nSigned-off-by: PoAn Yang \r\n\r\nReviewers: Luke Chen ","shortMessageHtmlLink":"KAFKA-17508: Adding some guard for fallback deletion logic (apache#17154"}},{"before":"6b5d172dcfa305dcd9c140be13cd65d4c5656761","after":"c977bfdd3cda4f7f4d3313d02e151df756872800","ref":"refs/heads/trunk","pushedAt":"2024-08-29T09:33:07.000Z","pushType":"push","commitsCount":165,"pusher":{"login":"clolov","name":"Christo Lolov","path":"/clolov","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/20223851?s=80&v=4"},"commit":{"message":"KAFKA-17413; Re-introduce `group.version` feature flag (#17013)\n\nThis patch re-introduces the `group.version` feature flag and gates the new consumer rebalance protocol with it. The `group.version` feature flag is attached to the metadata version `4.0-IV0` and it is marked as production ready. This allows system tests to pick it up directly by default without requiring to set `unstable.feature.versions.enable` in all of them. This is fine because we don't plan to do any incompatible changes before 4.0.\r\n\r\nReviewers: Justine Olshan , Chia-Ping Tsai ","shortMessageHtmlLink":"KAFKA-17413; Re-introduce group.version feature flag (apache#17013)"}},{"before":"f09ead14839877959a71aa4f43697a1a62132955","after":"6b5d172dcfa305dcd9c140be13cd65d4c5656761","ref":"refs/heads/trunk","pushedAt":"2024-08-07T07:33:07.000Z","pushType":"push","commitsCount":120,"pusher":{"login":"clolov","name":"Christo Lolov","path":"/clolov","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/20223851?s=80&v=4"},"commit":{"message":"KAFKA-12828: Removed Deprecated methods under KeyQueryMetadata (#16747)\n\nReviewers: Matthias J. Sax ","shortMessageHtmlLink":"KAFKA-12828: Removed Deprecated methods under KeyQueryMetadata (apach…"}},{"before":"ce0a4269c170df72a777c0d73225af3dad0bc68f","after":"f09ead14839877959a71aa4f43697a1a62132955","ref":"refs/heads/trunk","pushedAt":"2024-07-19T12:32:58.000Z","pushType":"push","commitsCount":20,"pusher":{"login":"clolov","name":"Christo Lolov","path":"/clolov","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/20223851?s=80&v=4"},"commit":{"message":"KAFKA-17132 Revisit testMissingOffsetNoResetPolicy for AsyncConsumer (#16587)\n\nReviewers: Chia-Ping Tsai ","shortMessageHtmlLink":"KAFKA-17132 Revisit testMissingOffsetNoResetPolicy for AsyncConsumer (a…"}},{"before":"f749af557a4d9ac3493aa329583260b8b16e2979","after":"ce0a4269c170df72a777c0d73225af3dad0bc68f","ref":"refs/heads/trunk","pushedAt":"2024-07-17T15:13:05.000Z","pushType":"push","commitsCount":18,"pusher":{"login":"clolov","name":"Christo Lolov","path":"/clolov","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/20223851?s=80&v=4"},"commit":{"message":"MINOR: Improve release script (#16613)\n\n* MINOR: Improve release script\r\nCo-authored-by: Igor Soarez \r\n\r\n---------\r\n\r\nSigned-off-by: Josep Prat \r\nCo-authored-by: Igor Soarez \r\n\r\nReviewers: Igor Soarez ","shortMessageHtmlLink":"MINOR: Improve release script (apache#16613)"}},{"before":"cfc7bb90ae40669d6eb284ae1987ce93b14990f4","after":"f749af557a4d9ac3493aa329583260b8b16e2979","ref":"refs/heads/trunk","pushedAt":"2024-07-15T13:26:09.000Z","pushType":"push","commitsCount":26,"pusher":{"login":"clolov","name":"Christo Lolov","path":"/clolov","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/20223851?s=80&v=4"},"commit":{"message":"MINOR: add some unit test for common Utils (#16549)\n\nReviewers: Ken Huang , Chia-Ping Tsai ","shortMessageHtmlLink":"MINOR: add some unit test for common Utils (apache#16549)"}},{"before":"6eb66bce995a9278b4332c35acb56002d48b6a30","after":"7aa30d9292193d2221fb15d293447f34251db69c","ref":"refs/heads/kafka-16851","pushedAt":"2024-07-09T18:13:06.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"clolov","name":"Christo Lolov","path":"/clolov","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/20223851?s=80&v=4"},"commit":{"message":"Fix identation","shortMessageHtmlLink":"Fix identation"}},{"before":"737ae70bb6c7a7a444f89a630fa07e329c385d86","after":"6eb66bce995a9278b4332c35acb56002d48b6a30","ref":"refs/heads/kafka-16851","pushedAt":"2024-07-09T18:12:20.000Z","pushType":"force_push","commitsCount":0,"pusher":{"login":"clolov","name":"Christo Lolov","path":"/clolov","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/20223851?s=80&v=4"},"commit":{"message":"Address comments","shortMessageHtmlLink":"Address comments"}},{"before":"a533e246e3ed5f6f6c5be4ebf9d29ae75cab557e","after":"cfc7bb90ae40669d6eb284ae1987ce93b14990f4","ref":"refs/heads/trunk","pushedAt":"2024-07-09T18:06:46.000Z","pushType":"push","commitsCount":7,"pusher":{"login":"clolov","name":"Christo Lolov","path":"/clolov","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/20223851?s=80&v=4"},"commit":{"message":"KAFKA-16345: Optionally URL-encode clientID and clientSecret in authorization header (#15475)\n\n\r\nReviewers: Mickael Maison , Kirk True ","shortMessageHtmlLink":"KAFKA-16345: Optionally URL-encode clientID and clientSecret in autho…"}},{"before":"641469e4ac15fafc362dab5aa5db49979782d5f0","after":"a533e246e3ed5f6f6c5be4ebf9d29ae75cab557e","ref":"refs/heads/trunk","pushedAt":"2024-07-08T09:06:47.000Z","pushType":"push","commitsCount":16,"pusher":{"login":"clolov","name":"Christo Lolov","path":"/clolov","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/20223851?s=80&v=4"},"commit":{"message":"KAFKA-17081 Tweak GroupCoordinatorConfig: re-introduce local attributes and validation (#16524)\n\nReviewers: Chia-Ping Tsai ","shortMessageHtmlLink":"KAFKA-17081 Tweak GroupCoordinatorConfig: re-introduce local attribut…"}},{"before":"ff594551e98b4a41b1ef30fb4a9cf82c0a03b254","after":"737ae70bb6c7a7a444f89a630fa07e329c385d86","ref":"refs/heads/kafka-16851","pushedAt":"2024-07-04T10:33:38.000Z","pushType":"force_push","commitsCount":0,"pusher":{"login":"clolov","name":"Christo Lolov","path":"/clolov","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/20223851?s=80&v=4"},"commit":{"message":"Address comments","shortMessageHtmlLink":"Address comments"}},{"before":"9a78122fb0b1b37961139d5c62e49fa758dc08ac","after":"641469e4ac15fafc362dab5aa5db49979782d5f0","ref":"refs/heads/trunk","pushedAt":"2024-07-04T09:42:22.000Z","pushType":"push","commitsCount":23,"pusher":{"login":"clolov","name":"Christo Lolov","path":"/clolov","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/20223851?s=80&v=4"},"commit":{"message":"KAFKA-17069: Remote log copy throttle metrics (#16086)\n\nAs part of KIP-956, we have added quota for remote copies to remote storage. In this PR, we are adding the following metrics for remote copy throttling.\r\n1. remote-copy-throttle-time-avg \tThe average time in millis remote copies was throttled by a broker\r\n2. remote-copy-throttle-time-max \tThe max time in millis remote copies was throttled by a broker\r\n\r\nAdded unit test for the metrics.\r\n\r\nReviewers: Kamal Chandraprakash, Luke Chen , Satish Duggana ","shortMessageHtmlLink":"KAFKA-17069: Remote log copy throttle metrics (apache#16086)"}},{"before":"3fa48830ccc2a4dab1b642107fc17f9bfe3a69bf","after":"ff594551e98b4a41b1ef30fb4a9cf82c0a03b254","ref":"refs/heads/kafka-16851","pushedAt":"2024-07-01T13:27:23.000Z","pushType":"force_push","commitsCount":0,"pusher":{"login":"clolov","name":"Christo Lolov","path":"/clolov","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/20223851?s=80&v=4"},"commit":{"message":"Address comments","shortMessageHtmlLink":"Address comments"}},{"before":"d1dd64ac0dc5cb1d2694a5aa6c03446187b7d6dc","after":"3fa48830ccc2a4dab1b642107fc17f9bfe3a69bf","ref":"refs/heads/kafka-16851","pushedAt":"2024-07-01T10:00:05.000Z","pushType":"force_push","commitsCount":0,"pusher":{"login":"clolov","name":"Christo Lolov","path":"/clolov","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/20223851?s=80&v=4"},"commit":{"message":"Address comments","shortMessageHtmlLink":"Address comments"}},{"before":"3f3b070a6a239dc801d4dd83c8ee55ccf497346b","after":"9a78122fb0b1b37961139d5c62e49fa758dc08ac","ref":"refs/heads/trunk","pushedAt":"2024-07-01T08:58:36.000Z","pushType":"push","commitsCount":32,"pusher":{"login":"clolov","name":"Christo Lolov","path":"/clolov","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/20223851?s=80&v=4"},"commit":{"message":"MINOR: Refactor GroupMetadataManager#consumerGroupHeartbeat and GroupMetadataManager#classicGroupJoinToConsumerGroup (#16371)\n\nThis patch is an attempt to simplifying GroupMetadataManager#consumerGroupHeartbeat and GroupMetadataManager#classicGroupJoinToConsumerGroup by sharing more of the common logic. It slightly change how static members are replaced too. Now, we generate the records to replace the member and then we update the member if needed.\r\n\r\nReviewers: Dongnuo Lyu , Chia-Ping Tsai , Justine Olshan ","shortMessageHtmlLink":"MINOR: Refactor GroupMetadataManager#consumerGroupHeartbeat and Group…"}},{"before":"83b9695d3c1241aa196825f96b6463ddf60d7af1","after":"d1dd64ac0dc5cb1d2694a5aa6c03446187b7d6dc","ref":"refs/heads/kafka-16851","pushedAt":"2024-06-25T09:29:49.000Z","pushType":"force_push","commitsCount":0,"pusher":{"login":"clolov","name":"Christo Lolov","path":"/clolov","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/20223851?s=80&v=4"},"commit":{"message":"KAFKA-16851: Add remote.log.disable.policy","shortMessageHtmlLink":"KAFKA-16851: Add remote.log.disable.policy"}},{"before":"768e90f6673fd484f0ca64a628cda4cb8383c385","after":"3f3b070a6a239dc801d4dd83c8ee55ccf497346b","ref":"refs/heads/trunk","pushedAt":"2024-06-25T09:21:33.000Z","pushType":"push","commitsCount":61,"pusher":{"login":"clolov","name":"Christo Lolov","path":"/clolov","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/20223851?s=80&v=4"},"commit":{"message":"KAFKA-16755: Implement lock timeout functionality in SharePartition (#16414)\n\nImplemented acquisition lock timeout functionality in SharePartition. Implemented the following functions -\r\n\r\n1. releaseAcquisitionLockOnTimeout - This function is executed when the acquisition lock timeout is reached. The function releases the acquired records.\r\n2. releaseAcquisitionLockOnTimeoutForCompleteBatch - Function which releases acquired records due to acquisition lock timeout maintained at a batch level.\r\n3. releaseAcquisitionLockOnTimeoutForPerOffsetBatch - Function which releases acquired records due to acquisition lock timeout maintained at an offset level.\r\n\r\nReviewers: Andrew Schofield , Apoorv Mittal , Manikumar Reddy ,","shortMessageHtmlLink":"KAFKA-16755: Implement lock timeout functionality in SharePartition (a…"}},{"before":"9368ef81b5cc6ce149979ff916c14709d1f2e491","after":"768e90f6673fd484f0ca64a628cda4cb8383c385","ref":"refs/heads/trunk","pushedAt":"2024-06-17T09:10:01.000Z","pushType":"push","commitsCount":55,"pusher":{"login":"clolov","name":"Christo Lolov","path":"/clolov","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/20223851?s=80&v=4"},"commit":{"message":"KAFKA-16669 Remove extra collection copy when generating DescribeAclsResource (#15924)\n\nReviewers: Chia-Ping Tsai ","shortMessageHtmlLink":"KAFKA-16669 Remove extra collection copy when generating DescribeAcls…"}},{"before":"778949b635908628a84455e5edd30462130f989b","after":"8b6df2355e0425f7b641f91bd59272609360ada8","ref":"refs/heads/kip-1005-kafka-16480","pushedAt":"2024-06-12T16:11:44.000Z","pushType":"force_push","commitsCount":0,"pusher":{"login":"clolov","name":"Christo Lolov","path":"/clolov","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/20223851?s=80&v=4"},"commit":{"message":"Address review comments","shortMessageHtmlLink":"Address review comments"}},{"before":"af86e56fcdf20d35b04639399cc81b3a1223fe6b","after":"9368ef81b5cc6ce149979ff916c14709d1f2e491","ref":"refs/heads/trunk","pushedAt":"2024-06-12T16:04:49.000Z","pushType":"push","commitsCount":19,"pusher":{"login":"clolov","name":"Christo Lolov","path":"/clolov","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/20223851?s=80&v=4"},"commit":{"message":"KAFKA-16865: Add IncludeTopicAuthorizedOperations option for DescribeTopicPartitionsRequest (#16136)\n\n\r\nReviewers: Mickael Maison , Chia-Ping Tsai , Calvin Liu , Andrew Schofield , Apoorv Mittal ","shortMessageHtmlLink":"KAFKA-16865: Add IncludeTopicAuthorizedOperations option for Describe…"}},{"before":"a41f7a4e13bfdb21fcd84dcf0baad3f2f4511479","after":"af86e56fcdf20d35b04639399cc81b3a1223fe6b","ref":"refs/heads/trunk","pushedAt":"2024-06-11T09:13:28.000Z","pushType":"push","commitsCount":39,"pusher":{"login":"clolov","name":"Christo Lolov","path":"/clolov","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/20223851?s=80&v=4"},"commit":{"message":"KAFKA-10787 Apply spotless to tools and tools-api module (#16262)\n\nReviewers: Chia-Ping Tsai ","shortMessageHtmlLink":"KAFKA-10787 Apply spotless to tools and tools-api module (apache#16262)"}},{"before":"5dabbe60fccef32a16b6cc50cd93bedee198d77e","after":"778949b635908628a84455e5edd30462130f989b","ref":"refs/heads/kip-1005-kafka-16480","pushedAt":"2024-06-06T18:03:04.000Z","pushType":"force_push","commitsCount":0,"pusher":{"login":"clolov","name":"Christo Lolov","path":"/clolov","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/20223851?s=80&v=4"},"commit":{"message":"Address review comments","shortMessageHtmlLink":"Address review comments"}},{"before":"55d38efcc5505a5a1bddb08ba05f4d923f8050f9","after":"a41f7a4e13bfdb21fcd84dcf0baad3f2f4511479","ref":"refs/heads/trunk","pushedAt":"2024-06-06T17:51:43.000Z","pushType":"push","commitsCount":29,"pusher":{"login":"clolov","name":"Christo Lolov","path":"/clolov","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/20223851?s=80&v=4"},"commit":{"message":"KAFKA-16884 Refactor RemoteLogManagerConfig with AbstractConfig (#16199)\n\nReviewers: Greg Harris , Kamal Chandraprakash , Chia-Ping Tsai ","shortMessageHtmlLink":"KAFKA-16884 Refactor RemoteLogManagerConfig with AbstractConfig (apac…"}},{"before":"f3ab48aeaff3b88d6f64a8bb22439af2a309aea3","after":"5dabbe60fccef32a16b6cc50cd93bedee198d77e","ref":"refs/heads/kip-1005-kafka-16480","pushedAt":"2024-06-04T18:14:01.000Z","pushType":"force_push","commitsCount":0,"pusher":{"login":"clolov","name":"Christo Lolov","path":"/clolov","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/20223851?s=80&v=4"},"commit":{"message":"Address review comments","shortMessageHtmlLink":"Address review comments"}},{"before":"a68a1cce824a8346509d5194e0e43a3cb36ba09a","after":"55d38efcc5505a5a1bddb08ba05f4d923f8050f9","ref":"refs/heads/trunk","pushedAt":"2024-06-04T17:59:17.000Z","pushType":"push","commitsCount":20,"pusher":{"login":"clolov","name":"Christo Lolov","path":"/clolov","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/20223851?s=80&v=4"},"commit":{"message":"KAFKA-15852: Move LinuxIoMetricsCollector to server module (#16178)\n\n\r\nReviewers: Chia-Ping Tsai ","shortMessageHtmlLink":"KAFKA-15852: Move LinuxIoMetricsCollector to server module (apache#16178"}},{"before":"22fb85d2ab88bd7845dabf89af0f2e931a2b2d3f","after":"f3ab48aeaff3b88d6f64a8bb22439af2a309aea3","ref":"refs/heads/kip-1005-kafka-16480","pushedAt":"2024-06-03T15:11:15.000Z","pushType":"force_push","commitsCount":0,"pusher":{"login":"clolov","name":"Christo Lolov","path":"/clolov","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/20223851?s=80&v=4"},"commit":{"message":"Move ELR to 4.0 IBP","shortMessageHtmlLink":"Move ELR to 4.0 IBP"}}],"hasNextPage":true,"hasPreviousPage":false,"activityType":"all","actor":null,"timePeriod":"all","sort":"DESC","perPage":30,"startCursor":"Y3Vyc29yOnYyOpK7MjAyNC0wOS0yN1QxMjoxNjoyNC4wMDAwMDBazwAAAATCkZSC","endCursor":"Y3Vyc29yOnYyOpK7MjAyNC0wNi0wM1QxNToxMToxNS4wMDAwMDBazwAAAARbFswm"}},"title":"Activity · clolov/kafka"}