{"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:1718051911.0","currentOid":""},"activityList":{"items":[{"before":"615e6e705c6fe56d1badcd7e85581efd6abb75c6","after":"dd755b7ea95b3f9c277d9778d6624ab05407cac6","ref":"refs/heads/trunk","pushedAt":"2024-06-12T19:48:32.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"rajinisivaram","name":"Rajini Sivaram","path":"/rajinisivaram","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/13164074?s=80&v=4"},"commit":{"message":"KAFKA-8206: KIP-899: Allow client to rebootstrap  (#13277)\n\nThis commit implements KIP-899: Allow producer and consumer clients to rebootstrap. It introduces the new setting `metadata.recovery.strategy`, applicable to all the types of clients.\r\n\r\nReviewers: Greg Harris <gharris1727@gmail.com>, Rajini Sivaram <rajinisivaram@googlemail.com>","shortMessageHtmlLink":"<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/KAFKA-8206\">KAFKA-8206</a>: KIP-899: Allow client to rebootstrap (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"1590681116\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/kafka/issues/13277\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/kafka/pull/13277/hovercard\" href=\"https://github.com/apache/kafka/pull/13277\">#13277</a>)"}},{"before":"72e72e3537de863d90d437184cf3711887ac7e57","after":"0e7134c1059029d821d09364418031a47842c73e","ref":"refs/heads/3.8","pushedAt":"2024-06-12T16:18:14.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"edoardocomar","name":"Edoardo Comar","path":"/edoardocomar","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/6661532?s=80&v=4"},"commit":{"message":"KAFKA-16570 FenceProducers API returns \"unexpected error\" when succes… (#16229)\n\nKAFKA-16570 FenceProducers API returns \"unexpected error\" when successful\r\n\r\n* Client handling of ConcurrentTransactionsException as retriable\r\n* Unit test\r\n* Integration test\r\n\r\nReviewers: Chris Egerton <chrise@aiven.io>, Justine Olshan <jolshan@confluent.io>","shortMessageHtmlLink":"<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/KAFKA-16570\">KAFKA-16570</a> FenceProducers API returns \"unexpected error\" when succes… ("}},{"before":"9368ef81b5cc6ce149979ff916c14709d1f2e491","after":"615e6e705c6fe56d1badcd7e85581efd6abb75c6","ref":"refs/heads/trunk","pushedAt":"2024-06-12T16:07:33.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"edoardocomar","name":"Edoardo Comar","path":"/edoardocomar","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/6661532?s=80&v=4"},"commit":{"message":"KAFKA-16570 FenceProducers API returns \"unexpected error\" when succes… (#16229)\n\nKAFKA-16570 FenceProducers API returns \"unexpected error\" when successful\r\n\r\n* Client handling of ConcurrentTransactionsException as retriable\r\n* Unit test\r\n* Integration test\r\n\r\nReviewers: Chris Egerton <chrise@aiven.io>, Justine Olshan <jolshan@confluent.io>","shortMessageHtmlLink":"<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/KAFKA-16570\">KAFKA-16570</a> FenceProducers API returns \"unexpected error\" when succes… ("}},{"before":"5fd9bd10abfed9eb3d200173591e26558c15f2af","after":"72e72e3537de863d90d437184cf3711887ac7e57","ref":"refs/heads/3.8","pushedAt":"2024-06-12T15:24:06.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"mimaison","name":"Mickael Maison","path":"/mimaison","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/903615?s=80&v=4"},"commit":{"message":"KAFKA-16865: Add IncludeTopicAuthorizedOperations option for DescribeTopicPartitionsRequest (#16136)\n\n\r\nReviewers: Mickael Maison <mickael.maison@gmail.com>, Chia-Ping Tsai <chia7712@gmail.com>, Calvin Liu <caliu@confluent.io>, Andrew Schofield <andrew_schofield@live.com>, Apoorv Mittal <amittal@confluent.io>","shortMessageHtmlLink":"<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/KAFKA-16865\">KAFKA-16865</a>: Add IncludeTopicAuthorizedOperations option for Describe…"}},{"before":"46eb0814f63236fa3c3532975ba76180485933fb","after":"9368ef81b5cc6ce149979ff916c14709d1f2e491","ref":"refs/heads/trunk","pushedAt":"2024-06-12T15:04:24.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"mimaison","name":"Mickael Maison","path":"/mimaison","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/903615?s=80&v=4"},"commit":{"message":"KAFKA-16865: Add IncludeTopicAuthorizedOperations option for DescribeTopicPartitionsRequest (#16136)\n\n\r\nReviewers: Mickael Maison <mickael.maison@gmail.com>, Chia-Ping Tsai <chia7712@gmail.com>, Calvin Liu <caliu@confluent.io>, Andrew Schofield <andrew_schofield@live.com>, Apoorv Mittal <amittal@confluent.io>","shortMessageHtmlLink":"<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/KAFKA-16865\">KAFKA-16865</a>: Add IncludeTopicAuthorizedOperations option for Describe…"}},{"before":"6016b15beabd774de6a358f5fdb62a336b7de43e","after":"5fd9bd10abfed9eb3d200173591e26558c15f2af","ref":"refs/heads/3.8","pushedAt":"2024-06-12T14:28:14.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"satishd","name":"Satish Duggana","path":"/satishd","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2577761?s=80&v=4"},"commit":{"message":"KAFKA-15265: Dynamic broker configs for remote fetch/copy quotas (#16078)\n\nReviewers: Kamal Chandraprakash<kamal.chandraprakash@gmail.com>, Satish Duggana <satishd@apache.org>","shortMessageHtmlLink":"<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/KAFKA-15265\">KAFKA-15265</a>: Dynamic broker configs for remote fetch/copy quotas (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2316152581\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/kafka/issues/16078\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/kafka/pull/16078/hovercard\" href=\"https://github.com/apache/kafka/pull/16078\">#16078</a>"}},{"before":"79b9c44acdbc8c3618bc61a6268791412593bf74","after":"46eb0814f63236fa3c3532975ba76180485933fb","ref":"refs/heads/trunk","pushedAt":"2024-06-12T14:23:39.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-10787 Apply spotless to log4j-appender, trogdor, jmh-benchmarks, examples, shell and generator (#16296)\n\nReviewers: Chia-Ping Tsai <chia7712@gmail.com>","shortMessageHtmlLink":"<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/KAFKA-10787\">KAFKA-10787</a> Apply spotless to log4j-appender, trogdor, jmh-benchmarks…"}},{"before":"b5fb6543a202f826461d5074ef0ea8f6022566e0","after":"79b9c44acdbc8c3618bc61a6268791412593bf74","ref":"refs/heads/trunk","pushedAt":"2024-06-12T14:19:47.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-10787 Apply spotless to connect module (#16299)\n\nReviewers: Chia-Ping Tsai <chia7712@gmail.com>","shortMessageHtmlLink":"<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/KAFKA-10787\">KAFKA-10787</a> Apply spotless to connect module (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2347915462\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/kafka/issues/16299\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/kafka/pull/16299/hovercard\" href=\"https://github.com/apache/kafka/pull/16299\">#16299</a>)"}},{"before":"faee6a4385c525c406606195357ca3b114c7a527","after":"b5fb6543a202f826461d5074ef0ea8f6022566e0","ref":"refs/heads/trunk","pushedAt":"2024-06-12T14:17:46.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-15265: Dynamic broker configs for remote fetch/copy quotas (#16078)\n\nReviewers: Kamal Chandraprakash<kamal.chandraprakash@gmail.com>, Satish Duggana <satishd@apache.org>","shortMessageHtmlLink":"<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/KAFKA-15265\">KAFKA-15265</a>: Dynamic broker configs for remote fetch/copy quotas (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2316152581\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/kafka/issues/16078\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/kafka/pull/16078/hovercard\" href=\"https://github.com/apache/kafka/pull/16078\">#16078</a>"}},{"before":"638844f833b165d6f9ca52c173858d26b7254fac","after":"faee6a4385c525c406606195357ca3b114c7a527","ref":"refs/heads/trunk","pushedAt":"2024-06-12T10:44:12.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"soarez","name":"Igor Soarez","path":"/soarez","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/1357510?s=80&v=4"},"commit":{"message":"MINOR: Use predetermined dir IDs in ReplicationQuotasTest\n\nUse predetermined directory IDs instead of Uuid.randomUuid() in ReplicationQuotasTest.\r\n\r\nReviewers: Igor Soarez <soarez@apple.com>","shortMessageHtmlLink":"MINOR: Use predetermined dir IDs in ReplicationQuotasTest"}},{"before":"8de153ebd6c44b12940b156a0d3ba4aa2795f6f8","after":"6016b15beabd774de6a358f5fdb62a336b7de43e","ref":"refs/heads/3.8","pushedAt":"2024-06-12T06:31:11.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"dajac","name":"David Jacot","path":"/dajac","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/157182?s=80&v=4"},"commit":{"message":"KAFKA-16770; [2/2] Coalesce records into bigger batches (#16215)\n\nThis patch is the continuation of https://github.com/apache/kafka/pull/15964. It introduces the records coalescing to the CoordinatorRuntime. It also introduces a new configuration `group.coordinator.append.linger.ms` which allows administrators to chose the linger time or disable it with zero. The new configuration defaults to 10ms.\r\n\r\nReviewers: Jeff Kim <jeff.kim@confluent.io>, Justine Olshan <jolshan@confluent.io>","shortMessageHtmlLink":"<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/KAFKA-16770\">KAFKA-16770</a>; [2/2] Coalesce records into bigger batches (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2336179443\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/kafka/issues/16215\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/kafka/pull/16215/hovercard\" href=\"https://github.com/apache/kafka/pull/16215\">#16215</a>)"}},{"before":"39ffdea6d321ef3dd5e787aef1b1102c33448c0f","after":"638844f833b165d6f9ca52c173858d26b7254fac","ref":"refs/heads/trunk","pushedAt":"2024-06-12T06:29:50.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":"KAFKA-16770; [2/2] Coalesce records into bigger batches (#16215)\n\nThis patch is the continuation of https://github.com/apache/kafka/pull/15964. It introduces the records coalescing to the CoordinatorRuntime. It also introduces a new configuration `group.coordinator.append.linger.ms` which allows administrators to chose the linger time or disable it with zero. The new configuration defaults to 10ms.\r\n\r\nReviewers: Jeff Kim <jeff.kim@confluent.io>, Justine Olshan <jolshan@confluent.io>","shortMessageHtmlLink":"<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/KAFKA-16770\">KAFKA-16770</a>; [2/2] Coalesce records into bigger batches (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2336179443\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/kafka/issues/16215\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/kafka/pull/16215/hovercard\" href=\"https://github.com/apache/kafka/pull/16215\">#16215</a>)"}},{"before":"77a6fe9c2a5d7d918536162c7db37b67c772d494","after":"8de153ebd6c44b12940b156a0d3ba4aa2795f6f8","ref":"refs/heads/3.8","pushedAt":"2024-06-12T05:54:58.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"cadonna","name":"Bruno Cadonna","path":"/cadonna","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/1042170?s=80&v=4"},"commit":{"message":"KAFKA-10199: Enable state updater by default (#16107)\n\nWe have already enabled the state updater by default once.\r\nHowever, we ran into issues that forced us to disable it again.\r\nWe think that we fixed those issues. So we want to enable the\r\nstate updater again by default.\r\n\r\nReviewers: Lucas Brutschy <lbrutschy@confluent.io>, Matthias J. Sax <matthias@confluent.io>","shortMessageHtmlLink":"<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/KAFKA-10199\">KAFKA-10199</a>: Enable state updater by default (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2321265799\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/kafka/issues/16107\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/kafka/pull/16107/hovercard\" href=\"https://github.com/apache/kafka/pull/16107\">#16107</a>)"}},{"before":"0782232fbeb6313a316b930d12508d1d6148f3c9","after":"39ffdea6d321ef3dd5e787aef1b1102c33448c0f","ref":"refs/heads/trunk","pushedAt":"2024-06-12T05:51:38.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"cadonna","name":"Bruno Cadonna","path":"/cadonna","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/1042170?s=80&v=4"},"commit":{"message":"KAFKA-10199: Enable state updater by default (#16107)\n\nWe have already enabled the state updater by default once.\r\nHowever, we ran into issues that forced us to disable it again.\r\nWe think that we fixed those issues. So we want to enable the\r\nstate updater again by default.\r\n\r\nReviewers: Lucas Brutschy <lbrutschy@confluent.io>, Matthias J. Sax <matthias@confluent.io>","shortMessageHtmlLink":"<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/KAFKA-10199\">KAFKA-10199</a>: Enable state updater by default (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2321265799\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/kafka/issues/16107\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/kafka/pull/16107/hovercard\" href=\"https://github.com/apache/kafka/pull/16107\">#16107</a>)"}},{"before":"0b4fcbb16d0fbab67df906bdfe0bb7b880503e22","after":"77a6fe9c2a5d7d918536162c7db37b67c772d494","ref":"refs/heads/3.8","pushedAt":"2024-06-12T04:35:25.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"ableegoldman","name":"A. Sophie Blee-Goldman","path":"/ableegoldman","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/4843099?s=80&v=4"},"commit":{"message":"KAFKA-15045: (KIP-924 pt. 22) Add RackAwareOptimizationParams and other minor TaskAssignmentUtils changes (#16294)\n\nWe now provide a way to more easily customize the rack aware\r\noptimizations that we provide by way of a configuration class called\r\nRackAwareOptimizationParams.\r\n\r\nWe also simplified the APIs for the optimizeXYZ utility functions since\r\nthey were mutating the inputs anyway.\r\n\r\nReviewers: Anna Sophie Blee-Goldman <ableegoldman@apache.org>","shortMessageHtmlLink":"<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/KAFKA-15045\">KAFKA-15045</a>: (KIP-924 pt. 22) Add RackAwareOptimizationParams and oth…"}},{"before":"226ac5e8fca181dc6e1241df78da55659e5240bf","after":"0782232fbeb6313a316b930d12508d1d6148f3c9","ref":"refs/heads/trunk","pushedAt":"2024-06-12T04:31:43.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"ableegoldman","name":"A. Sophie Blee-Goldman","path":"/ableegoldman","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/4843099?s=80&v=4"},"commit":{"message":"KAFKA-15045: (KIP-924 pt. 22) Add RackAwareOptimizationParams and other minor TaskAssignmentUtils changes (#16294)\n\nWe now provide a way to more easily customize the rack aware\r\noptimizations that we provide by way of a configuration class called\r\nRackAwareOptimizationParams.\r\n\r\nWe also simplified the APIs for the optimizeXYZ utility functions since\r\nthey were mutating the inputs anyway.\r\n\r\nReviewers: Anna Sophie Blee-Goldman <ableegoldman@apache.org>","shortMessageHtmlLink":"<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/KAFKA-15045\">KAFKA-15045</a>: (KIP-924 pt. 22) Add RackAwareOptimizationParams and oth…"}},{"before":"23fe71d579f84d59ebfe6d5a29e688315cec1285","after":"226ac5e8fca181dc6e1241df78da55659e5240bf","ref":"refs/heads/trunk","pushedAt":"2024-06-12T03:38:51.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-16922 Adding unit tests for NewTopic  (#16255)\n\nReviewers: Chia-Ping Tsai <chia7712@gmail.com>","shortMessageHtmlLink":"<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/KAFKA-16922\">KAFKA-16922</a> Adding unit tests for NewTopic (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2342128137\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/kafka/issues/16255\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/kafka/pull/16255/hovercard\" href=\"https://github.com/apache/kafka/pull/16255\">#16255</a>)"}},{"before":"7c30eed66c478623da8d0ee22a7379d077ef73e7","after":"0b4fcbb16d0fbab67df906bdfe0bb7b880503e22","ref":"refs/heads/3.8","pushedAt":"2024-06-12T01:25:27.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"satishd","name":"Satish Duggana","path":"/satishd","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2577761?s=80&v=4"},"commit":{"message":"KAFKA-15265: Integrate RLMQuotaManager for throttling copies to remote storage (#15820)\n\n- Added the integration of the quota manager to throttle copy requests to the remote storage. Reference KIP-956\r\n- Added unit-tests for the copy throttling logic.\r\n\r\nReviewers: Satish Duggana <satishd@apache.org>, Luke Chen <showuon@gmail.com>, Kamal Chandraprakash<kamal.chandraprakash@gmail.com>","shortMessageHtmlLink":"<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/KAFKA-15265\">KAFKA-15265</a>: Integrate RLMQuotaManager for throttling copies to remot…"}},{"before":"520fbb4116b92bbb362e2a67f0b20ffc644f2903","after":"7c30eed66c478623da8d0ee22a7379d077ef73e7","ref":"refs/heads/3.8","pushedAt":"2024-06-12T01:14:18.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"satishd","name":"Satish Duggana","path":"/satishd","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2577761?s=80&v=4"},"commit":{"message":"KAFKA-16541 Fix potential leader-epoch checkpoint file corruption (#15993)\n\nA patch for KAFKA-15046 got rid of fsync on LeaderEpochFileCache#truncateFromStart/End for performance reason, but it turned out this could cause corrupted leader-epoch checkpoint file on ungraceful OS shutdown, i.e. OS shuts down in the middle when kernel is writing dirty pages back to the device.\r\n\r\nTo address this problem, this PR makes below changes: (1) Revert LeaderEpochCheckpoint#write to always fsync\r\n(2) truncateFromStart/End now call LeaderEpochCheckpoint#write asynchronously on scheduler thread\r\n(3) UnifiedLog#maybeCreateLeaderEpochCache now loads epoch entries from checkpoint file only when current cache is absent\r\n\r\nReviewers: Jun Rao <junrao@gmail.com>","shortMessageHtmlLink":"<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/KAFKA-16541\">KAFKA-16541</a> Fix potential leader-epoch checkpoint file corruption (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2304619924\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/kafka/issues/15993\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/kafka/pull/15993/hovercard\" href=\"https://github.com/apache/kafka/pull/15993\">#1…</a>"}},{"before":"2fa2c72581de641a8d62b8124209b75f75152b78","after":"23fe71d579f84d59ebfe6d5a29e688315cec1285","ref":"refs/heads/trunk","pushedAt":"2024-06-12T00:57:02.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-15265: Integrate RLMQuotaManager for throttling copies to remote storage (#15820)\n\n- Added the integration of the quota manager to throttle copy requests to the remote storage. Reference KIP-956\r\n- Added unit-tests for the copy throttling logic.\r\n\r\nReviewers: Satish Duggana <satishd@apache.org>, Luke Chen <showuon@gmail.com>, Kamal Chandraprakash<kamal.chandraprakash@gmail.com>","shortMessageHtmlLink":"<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/KAFKA-15265\">KAFKA-15265</a>: Integrate RLMQuotaManager for throttling copies to remot…"}},{"before":"444e5de0834bc89d7abfbeb6a29809cc1b5c0934","after":"520fbb4116b92bbb362e2a67f0b20ffc644f2903","ref":"refs/heads/3.8","pushedAt":"2024-06-11T21:16:46.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"C0urante","name":"Chris Egerton","path":"/C0urante","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/8636148?s=80&v=4"},"commit":{"message":"MINOR: Wait for embedded clusters to start before using them in Connect OffsetsApiIntegrationTest (#16286)\n\nReviewers: Greg Harris <greg.harris@aiven.io>","shortMessageHtmlLink":"MINOR: Wait for embedded clusters to start before using them in Conne…"}},{"before":"8b6013f851fec537401f29769be5608c2d246747","after":"2fa2c72581de641a8d62b8124209b75f75152b78","ref":"refs/heads/trunk","pushedAt":"2024-06-11T21:15:07.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"C0urante","name":"Chris Egerton","path":"/C0urante","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/8636148?s=80&v=4"},"commit":{"message":"MINOR: Wait for embedded clusters to start before using them in Connect OffsetsApiIntegrationTest (#16286)\n\nReviewers: Greg Harris <greg.harris@aiven.io>","shortMessageHtmlLink":"MINOR: Wait for embedded clusters to start before using them in Conne…"}},{"before":"5c13a6cf2f2bb37a6f7b80595483a56cbd85a77f","after":"444e5de0834bc89d7abfbeb6a29809cc1b5c0934","ref":"refs/heads/3.8","pushedAt":"2024-06-11T19:26:54.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"ableegoldman","name":"A. Sophie Blee-Goldman","path":"/ableegoldman","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/4843099?s=80&v=4"},"commit":{"message":"KAFKA-15045: (KIP-924 pt. 21) UUID to ProcessId migration (#16269)\n\nThis PR changes the assignment process to use ProcessId instead of UUID.\r\n\r\nReviewers: Anna Sophie Blee-Goldman <ableegoldman@apache.org>","shortMessageHtmlLink":"<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/KAFKA-15045\">KAFKA-15045</a>: (KIP-924 pt. 21) UUID to ProcessId migration (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2344275349\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/kafka/issues/16269\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/kafka/pull/16269/hovercard\" href=\"https://github.com/apache/kafka/pull/16269\">#16269</a>)"}},{"before":"ac2a642ba99cde8a398510ce5cf503462863b489","after":"8b6013f851fec537401f29769be5608c2d246747","ref":"refs/heads/trunk","pushedAt":"2024-06-11T19:24:44.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"ableegoldman","name":"A. Sophie Blee-Goldman","path":"/ableegoldman","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/4843099?s=80&v=4"},"commit":{"message":"KAFKA-15045: (KIP-924 pt. 21) UUID to ProcessId migration (#16269)\n\nThis PR changes the assignment process to use ProcessId instead of UUID.\r\n\r\nReviewers: Anna Sophie Blee-Goldman <ableegoldman@apache.org>","shortMessageHtmlLink":"<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/KAFKA-15045\">KAFKA-15045</a>: (KIP-924 pt. 21) UUID to ProcessId migration (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2344275349\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/kafka/issues/16269\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/kafka/pull/16269/hovercard\" href=\"https://github.com/apache/kafka/pull/16269\">#16269</a>)"}},{"before":"46d7e44d1b6ed7807e5ec692f397a3d4118155b5","after":"5c13a6cf2f2bb37a6f7b80595483a56cbd85a77f","ref":"refs/heads/3.8","pushedAt":"2024-06-11T19:20:35.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"C0urante","name":"Chris Egerton","path":"/C0urante","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/8636148?s=80&v=4"},"commit":{"message":"MINOR: Fix flaky test ConnectWorkerIntegrationTest::testReconfigureConnectorWithFailingTaskConfigs (#16273)\n\nReviewers: Greg Harris <greg.harris@aiven.io>","shortMessageHtmlLink":"MINOR: Fix flaky test ConnectWorkerIntegrationTest::testReconfigureCo…"}},{"before":"98f7da9172c080592c22b241e2760435d2b48195","after":"ac2a642ba99cde8a398510ce5cf503462863b489","ref":"refs/heads/trunk","pushedAt":"2024-06-11T19:13:35.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"C0urante","name":"Chris Egerton","path":"/C0urante","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/8636148?s=80&v=4"},"commit":{"message":"MINOR: Fix flaky test ConnectWorkerIntegrationTest::testReconfigureConnectorWithFailingTaskConfigs (#16273)\n\nReviewers: Greg Harris <greg.harris@aiven.io>","shortMessageHtmlLink":"MINOR: Fix flaky test ConnectWorkerIntegrationTest::testReconfigureCo…"}},{"before":"bcd95f6485cd94fc489b0c1eba976ecda517d086","after":"46d7e44d1b6ed7807e5ec692f397a3d4118155b5","ref":"refs/heads/3.8","pushedAt":"2024-06-11T18:45:50.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"dajac","name":"David Jacot","path":"/dajac","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/157182?s=80&v=4"},"commit":{"message":"KAFKA-16930; UniformHeterogeneousAssignmentBuilder throws NPE when one member has no subscriptions (#16283)\n\nFix the following NPE:\r\n\r\n```\r\njava.lang.NullPointerException: Cannot invoke \"org.apache.kafka.coordinator.group.assignor.MemberAssignment.targetPartitions()\" because the return value of \"java.util.Map.get(Object)\" is null\r\n\tat org.apache.kafka.coordinator.group.assignor.GeneralUniformAssignmentBuilder.canMemberParticipateInReassignment(GeneralUniformAssignmentBuilder.java:248)\r\n\tat org.apache.kafka.coordinator.group.assignor.GeneralUniformAssignmentBuilder.balance(GeneralUniformAssignmentBuilder.java:336)\r\n\tat org.apache.kafka.coordinator.group.assignor.GeneralUniformAssignmentBuilder.buildAssignment(GeneralUniformAssignmentBuilder.java:157)\r\n\tat org.apache.kafka.coordinator.group.assignor.UniformAssignor.assign(UniformAssignor.java:84)\r\n\tat org.apache.kafka.coordinator.group.consumer.TargetAssignmentBuilder.build(TargetAssignmentBuilder.java:302)\r\n\tat org.apache.kafka.coordinator.group.GroupMetadataManager.updateTargetAssignment(GroupMetadataManager.java:1913)\r\n\tat org.apache.kafka.coordinator.group.GroupMetadataManager.consumerGroupHeartbeat(GroupMetadataManager.java:1518)\r\n\tat org.apache.kafka.coordinator.group.GroupMetadataManager.consumerGroupHeartbeat(GroupMetadataManager.java:2254)\r\n\tat org.apache.kafka.coordinator.group.GroupCoordinatorShard.consumerGroupHeartbeat(GroupCoordinatorShard.java:308)\r\n\tat org.apache.kafka.coordinator.group.GroupCoordinatorService.lambda$consumerGroupHeartbeat$0(GroupCoordinatorService.java:298)\r\n\tat org.apache.kafka.coordinator.group.runtime.CoordinatorRuntime$CoordinatorWriteEvent.lambda$run$0(CoordinatorRuntime.java:769)\r\n\tat org.apache.kafka.coordinator.group.runtime.CoordinatorRuntime.withActiveContextOrThrow(CoordinatorRuntime.java:1582)\r\n\tat org.apache.kafka.coordinator.group.runtime.CoordinatorRuntime.access$1400(CoordinatorRuntime.java:96)\r\n\tat org.apache.kafka.coordinator.group.runtime.CoordinatorRuntime$CoordinatorWriteEvent.run(CoordinatorRuntime.java:767)\r\n\tat org.apache.kafka.coordinator.group.runtime.MultiThreadedEventProcessor$EventProcessorThread.handleEvents(MultiThreadedEventProcessor.java:144)\r\n\tat org.apache.kafka.coordinator.group.runtime.MultiThreadedEventProcessor$EventProcessorThread.run(MultiThreadedEventProcessor.java:176) \r\n```\r\n\r\nReviewers: Lianet Magrans <lianetmr@gmail.com>, Justine Olshan <jolshan@confluent.io>","shortMessageHtmlLink":"<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/KAFKA-16930\">KAFKA-16930</a>; UniformHeterogeneousAssignmentBuilder throws NPE when on…"}},{"before":"aecaf4447561edd8da9f06e3abdf46f382dc9d89","after":"98f7da9172c080592c22b241e2760435d2b48195","ref":"refs/heads/trunk","pushedAt":"2024-06-11T18:43:56.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":"KAFKA-16930; UniformHeterogeneousAssignmentBuilder throws NPE when one member has no subscriptions (#16283)\n\nFix the following NPE:\r\n\r\n```\r\njava.lang.NullPointerException: Cannot invoke \"org.apache.kafka.coordinator.group.assignor.MemberAssignment.targetPartitions()\" because the return value of \"java.util.Map.get(Object)\" is null\r\n\tat org.apache.kafka.coordinator.group.assignor.GeneralUniformAssignmentBuilder.canMemberParticipateInReassignment(GeneralUniformAssignmentBuilder.java:248)\r\n\tat org.apache.kafka.coordinator.group.assignor.GeneralUniformAssignmentBuilder.balance(GeneralUniformAssignmentBuilder.java:336)\r\n\tat org.apache.kafka.coordinator.group.assignor.GeneralUniformAssignmentBuilder.buildAssignment(GeneralUniformAssignmentBuilder.java:157)\r\n\tat org.apache.kafka.coordinator.group.assignor.UniformAssignor.assign(UniformAssignor.java:84)\r\n\tat org.apache.kafka.coordinator.group.consumer.TargetAssignmentBuilder.build(TargetAssignmentBuilder.java:302)\r\n\tat org.apache.kafka.coordinator.group.GroupMetadataManager.updateTargetAssignment(GroupMetadataManager.java:1913)\r\n\tat org.apache.kafka.coordinator.group.GroupMetadataManager.consumerGroupHeartbeat(GroupMetadataManager.java:1518)\r\n\tat org.apache.kafka.coordinator.group.GroupMetadataManager.consumerGroupHeartbeat(GroupMetadataManager.java:2254)\r\n\tat org.apache.kafka.coordinator.group.GroupCoordinatorShard.consumerGroupHeartbeat(GroupCoordinatorShard.java:308)\r\n\tat org.apache.kafka.coordinator.group.GroupCoordinatorService.lambda$consumerGroupHeartbeat$0(GroupCoordinatorService.java:298)\r\n\tat org.apache.kafka.coordinator.group.runtime.CoordinatorRuntime$CoordinatorWriteEvent.lambda$run$0(CoordinatorRuntime.java:769)\r\n\tat org.apache.kafka.coordinator.group.runtime.CoordinatorRuntime.withActiveContextOrThrow(CoordinatorRuntime.java:1582)\r\n\tat org.apache.kafka.coordinator.group.runtime.CoordinatorRuntime.access$1400(CoordinatorRuntime.java:96)\r\n\tat org.apache.kafka.coordinator.group.runtime.CoordinatorRuntime$CoordinatorWriteEvent.run(CoordinatorRuntime.java:767)\r\n\tat org.apache.kafka.coordinator.group.runtime.MultiThreadedEventProcessor$EventProcessorThread.handleEvents(MultiThreadedEventProcessor.java:144)\r\n\tat org.apache.kafka.coordinator.group.runtime.MultiThreadedEventProcessor$EventProcessorThread.run(MultiThreadedEventProcessor.java:176) \r\n```\r\n\r\nReviewers: Lianet Magrans <lianetmr@gmail.com>, Justine Olshan <jolshan@confluent.io>","shortMessageHtmlLink":"<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/KAFKA-16930\">KAFKA-16930</a>; UniformHeterogeneousAssignmentBuilder throws NPE when on…"}},{"before":"f3dbd7ed08a0a7af0e69de1ccca8b6171b698a62","after":"aecaf4447561edd8da9f06e3abdf46f382dc9d89","ref":"refs/heads/trunk","pushedAt":"2024-06-11T17:01:35.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-16520: Support KIP-853 in DescribeQuorum (#16106)\n\nAdd support for KIP-953 KRaft Quorum reconfiguration in the DescribeQuorum request and response.\r\nAlso add support to AdminClient.describeQuorum, so that users will be able to find the current set of\r\nquorum nodes, as well as their directories, via these RPCs.\r\n\r\nReviewers: Luke Chen <showuon@gmail.com>, Colin P. McCabe <cmccabe@apache.org>, Andrew Schofield <aschofield@confluent.io>","shortMessageHtmlLink":"<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/KAFKA-16520\">KAFKA-16520</a>: Support KIP-853 in DescribeQuorum (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2321217044\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/kafka/issues/16106\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/kafka/pull/16106/hovercard\" href=\"https://github.com/apache/kafka/pull/16106\">#16106</a>)"}},{"before":"15db8233179f0889def4d4f60df199fbde4dd88f","after":"bcd95f6485cd94fc489b0c1eba976ecda517d086","ref":"refs/heads/3.8","pushedAt":"2024-06-11T15:50:47.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"satishd","name":"Satish Duggana","path":"/satishd","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2577761?s=80&v=4"},"commit":{"message":"KAFKA-16904: Metric to measure the latency of remote read requests (#16209)\n\nReviewers: Satish Duggana <satishd@apache.org>, Christo Lolov <lolovc@amazon.com>, Luke Chen <showuon@gmail.com>","shortMessageHtmlLink":"<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/KAFKA-16904\">KAFKA-16904</a>: Metric to measure the latency of remote read requests (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2335630017\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/kafka/issues/16209\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/kafka/pull/16209/hovercard\" href=\"https://github.com/apache/kafka/pull/16209\">#…</a>"}}],"hasNextPage":true,"hasPreviousPage":false,"activityType":"all","actor":null,"timePeriod":"all","sort":"DESC","perPage":30,"cursor":"djE6ks8AAAAEY7IztgA","startCursor":null,"endCursor":null}},"title":"Activity · apache/kafka"}