{"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:1717145602.0","currentOid":""},"activityList":{"items":[{"before":"92ed1ed58694d1df9df386a286bb856dbefb683a","after":"a39f3ec815868e0d89b6c9d0dfd1b1b4bba08905","ref":"refs/heads/3.8","pushedAt":"2024-05-31T20:22:54.000Z","pushType":"push","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-16639 Ensure HeartbeatRequestManager generates leave request regardless of in-flight heartbeats. (#16017)\n\nFix the bug where the heartbeat is not sent when a newly created consumer is immediately closed.\r\n\r\nWhen there is a heartbeat request in flight and the consumer is then closed. In the current code, the HeartbeatRequestManager does not correctly send the closing heartbeat because a previous heartbeat request is still in flight. However, the closing heartbeat is only sent once, so in this situation, the broker will not know that the consumer has left the consumer group until the consumer's heartbeat times out.\r\nThis situation causes the broker to wait until the consumer's heartbeat times out before triggering a consumer group rebalance, which in turn affects message consumption.\r\n\r\nReviewers: Lianet Magrans <lianetmr@gmail.com>, 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-16639\">KAFKA-16639</a> Ensure HeartbeatRequestManager generates leave request re…"}},{"before":"5257451646acd89d9bc6c19506ce7d823744dafd","after":"92ed1ed58694d1df9df386a286bb856dbefb683a","ref":"refs/heads/3.8","pushedAt":"2024-05-31T20:19:42.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-16864; Optimize uniform (homogenous) assignor (#16088)\n\nThis patch optimizes uniform (homogenous) assignor by avoiding creating a copy of all the assignments. Instead, the assignor creates a copy only if the assignment is updated. It is a sort of copy-on-write. This change reduces the overhead of the TargetAssignmentBuilder when ran with the uniform (homogenous) assignor.\r\n\r\nTrunk:\r\n\r\n```\r\nBenchmark                                     (memberCount)  (partitionsToMemberRatio)  (topicCount)  Mode  Cnt   Score   Error  Units\r\nTargetAssignmentBuilderBenchmark.build                10000                         10           100  avgt    5  24.535 ± 1.583  ms/op\r\nTargetAssignmentBuilderBenchmark.build                10000                         10          1000  avgt    5  24.094 ± 0.223  ms/op\r\nJMH benchmarks done\r\n```\r\n\r\n```\r\nBenchmark                                       (assignmentType)  (assignorType)  (isRackAware)  (memberCount)  (partitionsToMemberRatio)  (subscriptionType)  (topicCount)  Mode  Cnt   Score   Error  Units\r\nServerSideAssignorBenchmark.doAssignment             INCREMENTAL         UNIFORM          false          10000                         10         HOMOGENEOUS           100  avgt    5  14.697 ± 0.133  ms/op\r\nServerSideAssignorBenchmark.doAssignment             INCREMENTAL         UNIFORM          false          10000                         10         HOMOGENEOUS          1000  avgt    5  15.073 ± 0.135  ms/op\r\nJMH benchmarks done\r\n```\r\n\r\nPatch:\r\n\r\n```\r\nBenchmark                                     (memberCount)  (partitionsToMemberRatio)  (topicCount)  Mode  Cnt  Score   Error  Units\r\nTargetAssignmentBuilderBenchmark.build                10000                         10           100  avgt    5  3.376 ± 0.577  ms/op\r\nTargetAssignmentBuilderBenchmark.build                10000                         10          1000  avgt    5  3.731 ± 0.359  ms/op\r\nJMH benchmarks done\r\n```\r\n\r\n```\r\nBenchmark                                       (assignmentType)  (assignorType)  (isRackAware)  (memberCount)  (partitionsToMemberRatio)  (subscriptionType)  (topicCount)  Mode  Cnt  Score   Error  Units\r\nServerSideAssignorBenchmark.doAssignment             INCREMENTAL         UNIFORM          false          10000                         10         HOMOGENEOUS           100  avgt    5  1.975 ± 0.086  ms/op\r\nServerSideAssignorBenchmark.doAssignment             INCREMENTAL         UNIFORM          false          10000                         10         HOMOGENEOUS          1000  avgt    5  2.026 ± 0.190  ms/op\r\nJMH benchmarks done\r\n```\r\n\r\nReviewers: Ritika Reddy <rreddy@confluent.io>, 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-16864\">KAFKA-16864</a>; Optimize uniform (homogenous) assignor (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2318945560\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/kafka/issues/16088\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/kafka/pull/16088/hovercard\" href=\"https://github.com/apache/kafka/pull/16088\">#16088</a>)"}},{"before":"ca9f4aeda769e05222e1734dd93ab95dc27d47eb","after":"fb566e48bf05d749f8db8da803a3570acf25bb11","ref":"refs/heads/trunk","pushedAt":"2024-05-31T20:17:59.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-16864; Optimize uniform (homogenous) assignor (#16088)\n\nThis patch optimizes uniform (homogenous) assignor by avoiding creating a copy of all the assignments. Instead, the assignor creates a copy only if the assignment is updated. It is a sort of copy-on-write. This change reduces the overhead of the TargetAssignmentBuilder when ran with the uniform (homogenous) assignor.\r\n\r\nTrunk:\r\n\r\n```\r\nBenchmark                                     (memberCount)  (partitionsToMemberRatio)  (topicCount)  Mode  Cnt   Score   Error  Units\r\nTargetAssignmentBuilderBenchmark.build                10000                         10           100  avgt    5  24.535 ± 1.583  ms/op\r\nTargetAssignmentBuilderBenchmark.build                10000                         10          1000  avgt    5  24.094 ± 0.223  ms/op\r\nJMH benchmarks done\r\n```\r\n\r\n```\r\nBenchmark                                       (assignmentType)  (assignorType)  (isRackAware)  (memberCount)  (partitionsToMemberRatio)  (subscriptionType)  (topicCount)  Mode  Cnt   Score   Error  Units\r\nServerSideAssignorBenchmark.doAssignment             INCREMENTAL         UNIFORM          false          10000                         10         HOMOGENEOUS           100  avgt    5  14.697 ± 0.133  ms/op\r\nServerSideAssignorBenchmark.doAssignment             INCREMENTAL         UNIFORM          false          10000                         10         HOMOGENEOUS          1000  avgt    5  15.073 ± 0.135  ms/op\r\nJMH benchmarks done\r\n```\r\n\r\nPatch:\r\n\r\n```\r\nBenchmark                                     (memberCount)  (partitionsToMemberRatio)  (topicCount)  Mode  Cnt  Score   Error  Units\r\nTargetAssignmentBuilderBenchmark.build                10000                         10           100  avgt    5  3.376 ± 0.577  ms/op\r\nTargetAssignmentBuilderBenchmark.build                10000                         10          1000  avgt    5  3.731 ± 0.359  ms/op\r\nJMH benchmarks done\r\n```\r\n\r\n```\r\nBenchmark                                       (assignmentType)  (assignorType)  (isRackAware)  (memberCount)  (partitionsToMemberRatio)  (subscriptionType)  (topicCount)  Mode  Cnt  Score   Error  Units\r\nServerSideAssignorBenchmark.doAssignment             INCREMENTAL         UNIFORM          false          10000                         10         HOMOGENEOUS           100  avgt    5  1.975 ± 0.086  ms/op\r\nServerSideAssignorBenchmark.doAssignment             INCREMENTAL         UNIFORM          false          10000                         10         HOMOGENEOUS          1000  avgt    5  2.026 ± 0.190  ms/op\r\nJMH benchmarks done\r\n```\r\n\r\nReviewers: Ritika Reddy <rreddy@confluent.io>, 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-16864\">KAFKA-16864</a>; Optimize uniform (homogenous) assignor (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2318945560\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/kafka/issues/16088\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/kafka/pull/16088/hovercard\" href=\"https://github.com/apache/kafka/pull/16088\">#16088</a>)"}},{"before":"190dd79457f4fa6811f51b23cf12e18dca97237b","after":"ca9f4aeda769e05222e1734dd93ab95dc27d47eb","ref":"refs/heads/trunk","pushedAt":"2024-05-31T20:14:15.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-16639 Ensure HeartbeatRequestManager generates leave request regardless of in-flight heartbeats. (#16017)\n\nFix the bug where the heartbeat is not sent when a newly created consumer is immediately closed.\r\n\r\nWhen there is a heartbeat request in flight and the consumer is then closed. In the current code, the HeartbeatRequestManager does not correctly send the closing heartbeat because a previous heartbeat request is still in flight. However, the closing heartbeat is only sent once, so in this situation, the broker will not know that the consumer has left the consumer group until the consumer's heartbeat times out.\r\nThis situation causes the broker to wait until the consumer's heartbeat times out before triggering a consumer group rebalance, which in turn affects message consumption.\r\n\r\nReviewers: Lianet Magrans <lianetmr@gmail.com>, 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-16639\">KAFKA-16639</a> Ensure HeartbeatRequestManager generates leave request re…"}},{"before":"0971924ebc7e65eb7055010d2400626d31967d8c","after":"5257451646acd89d9bc6c19506ce7d823744dafd","ref":"refs/heads/3.8","pushedAt":"2024-05-31T19:52:50.000Z","pushType":"push","commitsCount":2,"pusher":{"login":"dajac","name":"David Jacot","path":"/dajac","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/157182?s=80&v=4"},"commit":{"message":"KAFKA-16860; [2/2] Introduce group.version feature flag (#16149)\n\nThis patch updates the system tests to correctly enable the new consumer protocol/coordinator in the tests requiring them.\r\n\r\nI went with the simplest approach for now. Long term, I think that we should refactor the tests to better handle features and non-production features.\r\n\r\nI got a successful run of the consumer system tests with this patch combined with https://github.com/apache/kafka/pull/16120: https://confluent-kafka-branch-builder-system-test-results.s3-us-west-2.amazonaws.com/system-test-kafka-branch-builder--1717155071--dajac--KAFKA-16860-2--29028ae0dd/2024-05-31--001./2024-05-31--001./report.html.\r\n\r\nReviewers: 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-16860\">KAFKA-16860</a>; [2/2] Introduce group.version feature flag (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2327250141\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/kafka/issues/16149\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/kafka/pull/16149/hovercard\" href=\"https://github.com/apache/kafka/pull/16149\">#16149</a>)"}},{"before":"ba61ff0cd94dd50401998fff1be7f646d1239000","after":"190dd79457f4fa6811f51b23cf12e18dca97237b","ref":"refs/heads/trunk","pushedAt":"2024-05-31T19:49:26.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-16860; [2/2] Introduce group.version feature flag (#16149)\n\nThis patch updates the system tests to correctly enable the new consumer protocol/coordinator in the tests requiring them.\r\n\r\nI went with the simplest approach for now. Long term, I think that we should refactor the tests to better handle features and non-production features.\r\n\r\nI got a successful run of the consumer system tests with this patch combined with https://github.com/apache/kafka/pull/16120: https://confluent-kafka-branch-builder-system-test-results.s3-us-west-2.amazonaws.com/system-test-kafka-branch-builder--1717155071--dajac--KAFKA-16860-2--29028ae0dd/2024-05-31--001./2024-05-31--001./report.html.\r\n\r\nReviewers: 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-16860\">KAFKA-16860</a>; [2/2] Introduce group.version feature flag (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2327250141\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/kafka/issues/16149\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/kafka/pull/16149/hovercard\" href=\"https://github.com/apache/kafka/pull/16149\">#16149</a>)"}},{"before":"f8ad9ee8920debaf008c761f76a436ee5d7018a9","after":"ba61ff0cd94dd50401998fff1be7f646d1239000","ref":"refs/heads/trunk","pushedAt":"2024-05-31T19:48:55.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-16860; [1/2] Introduce group.version feature flag (#16120)\n\nThis patch introduces the `group.version` feature flag with one version:\r\n1) Version 1 enables the new consumer group rebalance protocol (KIP-848).\r\n\r\nReviewers: 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-16860\">KAFKA-16860</a>; [1/2] Introduce group.version feature flag (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2323103674\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/kafka/issues/16120\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/kafka/pull/16120/hovercard\" href=\"https://github.com/apache/kafka/pull/16120\">#16120</a>)"}},{"before":"9c2b1b8d0bfaeb2dbdbbbf581b8ae083af5f68f7","after":"f8ad9ee8920debaf008c761f76a436ee5d7018a9","ref":"refs/heads/trunk","pushedAt":"2024-05-31T19:24:01.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: update all-latency-avg documentation (#16148)\n\nChange description: from iterator create to close time.\r\n\r\nReviewers: Matthias J. Sax <matthias@confluent.io>","shortMessageHtmlLink":"MINOR: update all-latency-avg documentation (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2327241833\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/kafka/issues/16148\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/kafka/pull/16148/hovercard\" href=\"https://github.com/apache/kafka/pull/16148\">#16148</a>)"}},{"before":"cdd4455cb8be712954adf62326a154889e29bf7c","after":"9c2b1b8d0bfaeb2dbdbbbf581b8ae083af5f68f7","ref":"refs/heads/trunk","pushedAt":"2024-05-31T17:31:08.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"gharris1727","name":"Greg Harris","path":"/gharris1727","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/5856969?s=80&v=4"},"commit":{"message":"KAFKA-16809: Run Javadoc in CI (#16025)\n\nSigned-off-by: Greg Harris <greg.harris@aiven.io>\r\nReviewers: Mickael Maison <mickael.maison@gmail.com>","shortMessageHtmlLink":"<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/KAFKA-16809\">KAFKA-16809</a>: Run Javadoc in CI (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2309107169\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/kafka/issues/16025\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/kafka/pull/16025/hovercard\" href=\"https://github.com/apache/kafka/pull/16025\">#16025</a>)"}},{"before":"b6d0fb055d1b74c918f317027760e0bb7cf929a3","after":"cdd4455cb8be712954adf62326a154889e29bf7c","ref":"refs/heads/trunk","pushedAt":"2024-05-31T17:14:31.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-16866 Used the right constant in RemoteLogManagerTest#testFetchQuotaManagerConfig (#16152)\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-16866\">KAFKA-16866</a> Used the right constant in RemoteLogManagerTest#testFetch…"}},{"before":"7e81cc5e68a709d4df151ecd86d2b5e3f03d0fb3","after":"b6d0fb055d1b74c918f317027760e0bb7cf929a3","ref":"refs/heads/trunk","pushedAt":"2024-05-31T17:09:46.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: Refactor DynamicConfig (#16133)\n\nReviewers: Chia-Ping Tsai <chia7712@gmail.com>","shortMessageHtmlLink":"MINOR: Refactor DynamicConfig (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2325504885\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/kafka/issues/16133\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/kafka/pull/16133/hovercard\" href=\"https://github.com/apache/kafka/pull/16133\">#16133</a>)"}},{"before":"21caf6b123dd70a68d258fd925785a529f3a48d9","after":"7e81cc5e68a709d4df151ecd86d2b5e3f03d0fb3","ref":"refs/heads/trunk","pushedAt":"2024-05-31T14:41:44.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":"MINOR: Bump trunk to 3.9.0-SNAPSHOT (#16150)\n\nSigned-off-by: Josep Prat <josep.prat@aiven.io>\r\n\r\nReviewers: Mickael Maison <mickael.maison@gmail.com>, Chia-Ping Tsai <chia7712@gmail.com>","shortMessageHtmlLink":"MINOR: Bump trunk to 3.9.0-SNAPSHOT (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2327329296\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/kafka/issues/16150\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/kafka/pull/16150/hovercard\" href=\"https://github.com/apache/kafka/pull/16150\">#16150</a>)"}},{"before":"0971924ebc7e65eb7055010d2400626d31967d8c","after":"21caf6b123dd70a68d258fd925785a529f3a48d9","ref":"refs/heads/trunk","pushedAt":"2024-05-31T12:24:34.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-16629 Add broker-related tests to ConfigCommandIntegrationTest (#15840)\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-16629\">KAFKA-16629</a> Add broker-related tests to ConfigCommandIntegrationTest (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2273512798\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/kafka/issues/15840\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/kafka/pull/15840/hovercard\" href=\"https://github.com/apache/kafka/pull/15840\">#…</a>"}},{"before":"b0fb2ac06d81d656d6230ace5bcba0f9a62c61dc","after":"0971924ebc7e65eb7055010d2400626d31967d8c","ref":"refs/heads/3.8","pushedAt":"2024-05-31T08:54:53.000Z","pushType":"push","commitsCount":4,"pusher":{"login":"jlprat","name":"Josep Prat","path":"/jlprat","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/3337739?s=80&v=4"},"commit":{"message":"KAFKA-16824: Utils.getHost and Utils.getPort do not catch a lot of invalid host and ports. (#16048)\n\nModify regex of HOST_PORT_PATTERN to prevent malformed hosts and ports.\r\n\r\nReviewers: 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-16824\">KAFKA-16824</a>: Utils.getHost and Utils.getPort do not catch a lot of in…"}},{"before":null,"after":"b0fb2ac06d81d656d6230ace5bcba0f9a62c61dc","ref":"refs/heads/3.8","pushedAt":"2024-05-31T08:53:22.000Z","pushType":"branch_creation","commitsCount":0,"pusher":{"login":"jlprat","name":"Josep Prat","path":"/jlprat","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/3337739?s=80&v=4"},"commit":{"message":"KAFKA-16866 RemoteLogManagerTest.testCopyQuotaManagerConfig failing (#16146)\n\nReviewers: Justine Olshan <jolshan@confluent.io>, 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-16866\">KAFKA-16866</a> RemoteLogManagerTest.testCopyQuotaManagerConfig failing (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2326544833\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/kafka/issues/16146\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/kafka/pull/16146/hovercard\" href=\"https://github.com/apache/kafka/pull/16146\">#…</a>"}},{"before":"eb39031cd03fe94c8262f8c982222801842f6e6f","after":"0971924ebc7e65eb7055010d2400626d31967d8c","ref":"refs/heads/trunk","pushedAt":"2024-05-31T08:50:27.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"showuon","name":"Luke Chen","path":"/showuon","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/43372967?s=80&v=4"},"commit":{"message":"KAFKA-16824: Utils.getHost and Utils.getPort do not catch a lot of invalid host and ports. (#16048)\n\nModify regex of HOST_PORT_PATTERN to prevent malformed hosts and ports.\r\n\r\nReviewers: 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-16824\">KAFKA-16824</a>: Utils.getHost and Utils.getPort do not catch a lot of in…"}},{"before":"3d125a23224682a90c624b0cbe696c934d0b7aba","after":"eb39031cd03fe94c8262f8c982222801842f6e6f","ref":"refs/heads/trunk","pushedAt":"2024-05-31T08:33:21.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"lucasbru","name":"Lucas Brutschy","path":"/lucasbru","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/1628637?s=80&v=4"},"commit":{"message":"KAFKA-16766: offset fetch timeout exception in new consumer consistent with legacy (#16125)\n\n* Timeout exception fetching offsets\r\n\r\n* Tests","shortMessageHtmlLink":"<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/KAFKA-16766\">KAFKA-16766</a>: offset fetch timeout exception in new consumer consisten…"}},{"before":"76d1f18e42d3123438e9d3a91bd89d119bbbb785","after":"3d125a23224682a90c624b0cbe696c934d0b7aba","ref":"refs/heads/trunk","pushedAt":"2024-05-31T08:07:38.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"showuon","name":"Luke Chen","path":"/showuon","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/43372967?s=80&v=4"},"commit":{"message":"MINOR: Add more unit tests to LogSegments (#16085)\n\nadd more unit tests to LogSegments and do some small refactor in LogSegments.java\r\n\r\nReviewers: Luke Chen <showuon@gmail.com>, Chia-Ping Tsai <chia7712@gmail.com>","shortMessageHtmlLink":"MINOR: Add more unit tests to LogSegments (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2317857168\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/kafka/issues/16085\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/kafka/pull/16085/hovercard\" href=\"https://github.com/apache/kafka/pull/16085\">#16085</a>)"}},{"before":"b0fb2ac06d81d656d6230ace5bcba0f9a62c61dc","after":"76d1f18e42d3123438e9d3a91bd89d119bbbb785","ref":"refs/heads/trunk","pushedAt":"2024-05-31T07:56:36.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":"Revert \"KAFKA-16448: Add ProcessingExceptionHandler interface and implementations (#16090)\" (#16142)\n\nThis reverts commit 8d11d9579503426edfaeae791ec4bb212da37ad2.\r\n\r\nWe decided to not release KIP-1033 with AK 3.8\r\n\r\nReviewer: Lucas Brutschy <lbrutschy@confluent.io>","shortMessageHtmlLink":"Revert \"<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/KAFKA-16448\">KAFKA-16448</a>: Add ProcessingExceptionHandler interface and imp…"}},{"before":"370e5ea1f81b0cd64760f740981a388b76b5e29d","after":"b0fb2ac06d81d656d6230ace5bcba0f9a62c61dc","ref":"refs/heads/trunk","pushedAt":"2024-05-31T01:02:50.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-16866 RemoteLogManagerTest.testCopyQuotaManagerConfig failing (#16146)\n\nReviewers: Justine Olshan <jolshan@confluent.io>, 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-16866\">KAFKA-16866</a> RemoteLogManagerTest.testCopyQuotaManagerConfig failing (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2326544833\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/kafka/issues/16146\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/kafka/pull/16146/hovercard\" href=\"https://github.com/apache/kafka/pull/16146\">#…</a>"}},{"before":"7c1bb1585f31b1ec68b0f327e831ec2a909d824a","after":"370e5ea1f81b0cd64760f740981a388b76b5e29d","ref":"refs/heads/trunk","pushedAt":"2024-05-30T22:11:34.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. 15) Implement #defaultStandbyTaskAssignment and finish rack-aware standby optimization (#16129)\n\nThis fills in the implementation details of the standby task assignment utility functions within TaskAssignmentUtils.\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. 15) Implement #defaultStandbyTaskAssignment…"}},{"before":"a8e99eb969539bd38ae6ee572791b974b41f8433","after":"7c1bb1585f31b1ec68b0f327e831ec2a909d824a","ref":"refs/heads/trunk","pushedAt":"2024-05-30T21:52:50.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"jolshan","name":"Justine Olshan","path":"/jolshan","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/25566826?s=80&v=4"},"commit":{"message":"KAFKA-16308 [2/N]: Allow unstable feature versions and rename unstable metadata config (#16130)\n\nAs per KIP-1022, we will rename the unstable metadata versions enabled config to support all feature versions.\r\n\r\nFeatures is also updated to return latest production and latest testing versions of each feature.\r\n\r\nA feature is production ready when the corresponding metadata version (bootstrapMetadataVersion) is production ready.\r\n\r\nAdds tests for the feature usage of the unstableFeatureVersionsEnabled config\r\n\r\nReviewers: David Jacot <djacot@confluent.io>, 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-16308\">KAFKA-16308</a> [2/N]: Allow unstable feature versions and rename unstabl…"}},{"before":"e974914ca52509a2396e3939a6db6a4e9f9c7dfa","after":"a8e99eb969539bd38ae6ee572791b974b41f8433","ref":"refs/heads/trunk","pushedAt":"2024-05-30T21:00:42.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-16833 Fixing PartitionInfo and Cluster equals and hashCode (#16062)\n\nReviewers: Andrew Schofield <aschofield@confluent.io>, 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-16833\">KAFKA-16833</a> Fixing PartitionInfo and Cluster equals and hashCode (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2314015532\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/kafka/issues/16062\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/kafka/pull/16062/hovercard\" href=\"https://github.com/apache/kafka/pull/16062\">#16062</a>"}},{"before":"33a292e4dd9864bfd7142c55fc9a6e9d7f3b21e2","after":"e974914ca52509a2396e3939a6db6a4e9f9c7dfa","ref":"refs/heads/trunk","pushedAt":"2024-05-30T20:55:00.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: Code Cleanup - Connect Module (#16066)\n\nReviewers: Chia-Ping Tsai <chia7712@gmail.com>","shortMessageHtmlLink":"MINOR: Code Cleanup - Connect Module (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2314475387\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/kafka/issues/16066\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/kafka/pull/16066/hovercard\" href=\"https://github.com/apache/kafka/pull/16066\">#16066</a>)"}},{"before":"cd750582c085beac8ad68e58f674f1c1653c9fc5","after":"33a292e4dd9864bfd7142c55fc9a6e9d7f3b21e2","ref":"refs/heads/trunk","pushedAt":"2024-05-30T20:38:23.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: Adds a test case to test that an exception is thrown in invalid ports (#16112)\n\nReviewers: Chia-Ping Tsai <chia7712@gmail.com>","shortMessageHtmlLink":"MINOR: Adds a test case to test that an exception is thrown in invali…"}},{"before":"701f8e7ad4571cac7af7496f4a6e12e72ee54c09","after":"cd750582c085beac8ad68e58f674f1c1653c9fc5","ref":"refs/heads/trunk","pushedAt":"2024-05-30T19:35:30.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: Enable transaction verification with new group coordinator in TransactionsTest (#16139)\n\nWhile working on https://github.com/apache/kafka/pull/16120, I noticed that the transaction verification feature is disabled in `TransactionsTest` when the new group coordinator is enabled. We did this initially because the feature was not available in the new group coordinator but we fixed it a long time ago. We can enable it now.\r\n\r\nReviewers: Justine Olshan <jolshan@confluent.io>","shortMessageHtmlLink":"MINOR: Enable transaction verification with new group coordinator in …"}},{"before":"a626e873034aee2ed1293abc2b08e29dc266ea12","after":"701f8e7ad4571cac7af7496f4a6e12e72ee54c09","ref":"refs/heads/trunk","pushedAt":"2024-05-30T19:11:35.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"gharris1727","name":"Greg Harris","path":"/gharris1727","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/5856969?s=80&v=4"},"commit":{"message":"KAFKA-16802: Move java versions inside java block to resolve deprecation (#16135)\n\nReviewers: Greg Harris <greg.harris@aiven.io>","shortMessageHtmlLink":"<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/KAFKA-16802\">KAFKA-16802</a>: Move java versions inside java block to resolve deprecat…"}},{"before":"bb6a042e99a3d011968a75f4e2bfb51d57637a25","after":"a626e873034aee2ed1293abc2b08e29dc266ea12","ref":"refs/heads/trunk","pushedAt":"2024-05-30T18:36:11.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: Make public the consumer group migration policy config\n\nThis patch exposes the group coordinator config `CONSUMER_GROUP_MIGRATION_POLICY_CONFIG`.\r\n\r\nReviewers: Chia-Ping Tsai <chia7712@gmail.com>, David Jacot <djacot@confluent.io>","shortMessageHtmlLink":"MINOR: Make public the consumer group migration policy config"}},{"before":"bb7db87f9883a7023b28f1150085b0914c011379","after":"bb6a042e99a3d011968a75f4e2bfb51d57637a25","ref":"refs/heads/trunk","pushedAt":"2024-05-30T16:54:24.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"omkreddy","name":"Manikumar Reddy","path":"/omkreddy","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/8134545?s=80&v=4"},"commit":{"message":"KAFKA-16827: Integrate kafka native-image with system tests (#16046)\n\nThis PR does following things\r\n\r\nSystem tests should bring up Kafka broker in the native mode\r\nSystem tests should run on Kafka broker in native mode\r\nExtract out native build command so that it can be reused.\r\nAllow system tests to run on Native Kafka broker using Docker mechanism\r\n\r\nTo run system tests by bringing up Kafka in native mode:\r\nPass kafka_mode as native in the ducktape globals:--globals '{\\\"kafka_mode\\\":\\\"native\\\"}'\r\n\r\nRunning system tests by bringing up kafka in native mode via docker mechanism\r\n_DUCKTAPE_OPTIONS=\"--globals '{\\\"kafka_mode\\\":\\\"native\\\"}'\" TC_PATHS=\"tests/kafkatest/tests/\"  bash tests/docker/run_tests.sh\r\n\r\nTo only bring up ducker nodes to cater native kafka\r\nbash tests/docker/ducker-ak up -m native\r\n\r\nReviewers: Manikumar Reddy <manikumar.reddy@gmail.com>","shortMessageHtmlLink":"<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/KAFKA-16827\">KAFKA-16827</a>: Integrate kafka native-image with system tests (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2312969590\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/kafka/issues/16046\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/kafka/pull/16046/hovercard\" href=\"https://github.com/apache/kafka/pull/16046\">#16046</a>)"}},{"before":"fea3eeb7f7354f33042bd977802196d593f1ddad","after":"bb7db87f9883a7023b28f1150085b0914c011379","ref":"refs/heads/trunk","pushedAt":"2024-05-30T16:06:50.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"junrao","name":"Jun Rao","path":"/junrao","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/132330?s=80&v=4"},"commit":{"message":"KAFKA-15265: Add Remote Log Manager quota manager (#15625)\n\nAdded the implementation of the quota manager that will be used to throttle copy and fetch requests from the remote storage. Reference KIP-956\r\n\r\nReviewers: Luke Chen <showuon@gmail.com>, Kamal Chandraprakash <kchandraprakash@uber.com>, 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-15265\">KAFKA-15265</a>: Add Remote Log Manager quota manager (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2215234425\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/kafka/issues/15625\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/kafka/pull/15625/hovercard\" href=\"https://github.com/apache/kafka/pull/15625\">#15625</a>)"}}],"hasNextPage":true,"hasPreviousPage":false,"activityType":"all","actor":null,"timePeriod":"all","sort":"DESC","perPage":30,"cursor":"djE6ks8AAAAEWV9V3QA","startCursor":null,"endCursor":null}},"title":"Activity · apache/kafka"}