{"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":"9eb05fc72963fbb5667ecf00a252654b0cc1f8cc","after":"b05f82d44489b5744a1470d49896e322528c25da","ref":"refs/heads/trunk","pushedAt":"2024-06-02T14:18:53.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-16785 Migrate TopicBasedRemoteLogMetadataManagerRestartTest to new test infra (#16170)\n\nReviewers: Chia-Ping Tsai ","shortMessageHtmlLink":"KAFKA-16785 Migrate TopicBasedRemoteLogMetadataManagerRestartTest to …"}},{"before":"2c82ecd67f2f6b412f625e8efc1457e7fb7f74dd","after":"9eb05fc72963fbb5667ecf00a252654b0cc1f8cc","ref":"refs/heads/trunk","pushedAt":"2024-06-02T12:32:54.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-16223 Replace EasyMock/PowerMock with Mockito for KafkaConfigBackingStoreTest (#16164)\n\nReviewers: Chia-Ping Tsai ","shortMessageHtmlLink":" KAFKA-16223 Replace EasyMock/PowerMock with Mockito for KafkaConfigB…"}},{"before":"327b696b8a9412f35a83b14a16eac097728f4d5a","after":"1e9d0c4cd25876c44b2e579d9d5e99746cbf660b","ref":"refs/heads/3.7","pushedAt":"2024-06-02T09:47:08.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-16807 DescribeLogDirsResponseData#results#topics have unexpected topics having empty partitions (#16042)\n\nReviewers: Chia-Ping Tsai ","shortMessageHtmlLink":"KAFKA-16807 DescribeLogDirsResponseData#results#topics have unexpecte…"}},{"before":"34f5d5bab26c59fef325a72725c05d7563b38f44","after":"dc5a22bf830b57ad0688fd8d544d631523e1fa26","ref":"refs/heads/3.8","pushedAt":"2024-06-02T09:40:32.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-16807 DescribeLogDirsResponseData#results#topics have unexpected topics having empty partitions (#16042)\n\nReviewers: Chia-Ping Tsai ","shortMessageHtmlLink":"KAFKA-16807 DescribeLogDirsResponseData#results#topics have unexpecte…"}},{"before":"8ace33b47fc078d89a104043b12ca95f6e1da637","after":"2c82ecd67f2f6b412f625e8efc1457e7fb7f74dd","ref":"refs/heads/trunk","pushedAt":"2024-06-02T09:33:02.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-16807 DescribeLogDirsResponseData#results#topics have unexpected topics having empty partitions (#16042)\n\nReviewers: Chia-Ping Tsai ","shortMessageHtmlLink":"KAFKA-16807 DescribeLogDirsResponseData#results#topics have unexpecte…"}},{"before":"a39f3ec815868e0d89b6c9d0dfd1b1b4bba08905","after":"34f5d5bab26c59fef325a72725c05d7563b38f44","ref":"refs/heads/3.8","pushedAt":"2024-06-01T22:54:18.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"soarez","name":"Igor Soarez","path":"/soarez","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/1357510?s=80&v=4"},"commit":{"message":"KAFKA-16757: Fix broker re-registration issues around MV 3.7-IV2 (#15945)\n\nWhen upgrading from a MetadataVersion older than 3.7-IV2, we need to resend the broker registration, so that the controller can record the storage directories. The current code for doing this has several problems, however. One is that it tends to trigger even in cases where we don't actually need it. Another is that when re-registering the broker, the broker is marked as fenced.\r\n\r\nThis PR moves the handling of the re-registration case out of BrokerMetadataPublisher and into BrokerRegistrationTracker. The re-registration code there will only trigger in the case where the broker sees an existing registration for itself with no directories set. This is much more targetted than the original code.\r\n\r\nAdditionally, in ClusterControlManager, when re-registering the same broker, we now preserve its fencing and shutdown state, rather than clearing those. (There isn't any good reason re-registering the same broker should clear these things... this was purely an oversight.) Note that we can tell the broker is \"the same\" because it has the same IncarnationId.\r\n\r\nReviewers: Gaurav Narula , Igor Soarez ","shortMessageHtmlLink":"KAFKA-16757: Fix broker re-registration issues around MV 3.7-IV2 (#15945"}},{"before":"244b029fe2b023a673d4dd804514c8400db00111","after":"327b696b8a9412f35a83b14a16eac097728f4d5a","ref":"refs/heads/3.7","pushedAt":"2024-06-01T22:52:35.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"soarez","name":"Igor Soarez","path":"/soarez","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/1357510?s=80&v=4"},"commit":{"message":"KAFKA-16757: Fix broker re-registration issues around MV 3.7-IV2\n\nWhen upgrading from a MetadataVersion older than 3.7-IV2, we need to resend the broker registration, so that the controller can record the storage directories. The current code for doing this has several problems, however. One is that it tends to trigger even in cases where we don't actually need it. Another is that when re-registering the broker, the broker is marked as fenced.\n\nThis PR moves the handling of the re-registration case out of BrokerMetadataPublisher and into BrokerRegistrationTracker. The re-registration code there will only trigger in the case where the broker sees an existing registration for itself with no directories set. This is much more targetted than the original code.\n\nAdditionally, in ClusterControlManager, when re-registering the same broker, we now preserve its fencing and shutdown state, rather than clearing those. (There isn't any good reason re-registering the same broker should clear these things... this was purely an oversight.) Note that we can tell the broker is \"the same\" because it has the same IncarnationId.\n\nReviewers: Gaurav Narula , Igor Soarez ","shortMessageHtmlLink":"KAFKA-16757: Fix broker re-registration issues around MV 3.7-IV2"}},{"before":"966f2eb3efd929a4c270c502514aa74ea1414677","after":"8ace33b47fc078d89a104043b12ca95f6e1da637","ref":"refs/heads/trunk","pushedAt":"2024-06-01T22:51:39.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":"KAFKA-16757: Fix broker re-registration issues around MV 3.7-IV2 (#15945)\n\nWhen upgrading from a MetadataVersion older than 3.7-IV2, we need to resend the broker registration, so that the controller can record the storage directories. The current code for doing this has several problems, however. One is that it tends to trigger even in cases where we don't actually need it. Another is that when re-registering the broker, the broker is marked as fenced.\r\n\r\nThis PR moves the handling of the re-registration case out of BrokerMetadataPublisher and into BrokerRegistrationTracker. The re-registration code there will only trigger in the case where the broker sees an existing registration for itself with no directories set. This is much more targetted than the original code.\r\n\r\nAdditionally, in ClusterControlManager, when re-registering the same broker, we now preserve its fencing and shutdown state, rather than clearing those. (There isn't any good reason re-registering the same broker should clear these things... this was purely an oversight.) Note that we can tell the broker is \"the same\" because it has the same IncarnationId.\r\n\r\nReviewers: Gaurav Narula , Igor Soarez ","shortMessageHtmlLink":"KAFKA-16757: Fix broker re-registration issues around MV 3.7-IV2 (#15945"}},{"before":"355d5da79a82bce1956767dd573a6b0b6ac4b507","after":"966f2eb3efd929a4c270c502514aa74ea1414677","ref":"refs/heads/trunk","pushedAt":"2024-06-01T20:25:16.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: Add URL to log for Connect RestClient (#16166)\n\nReviewers: Chris Egerton ","shortMessageHtmlLink":"Minor: Add URL to log for Connect RestClient (#16166)"}},{"before":"e33eb82fedc7cc1d9031c68190b4da1052eda3d7","after":"355d5da79a82bce1956767dd573a6b0b6ac4b507","ref":"refs/heads/trunk","pushedAt":"2024-06-01T17:20:59.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: reduce the test suits of consumer group tools (#16155)\n\nReviewers: Chia-Ping Tsai ","shortMessageHtmlLink":"MINOR: reduce the test suits of consumer group tools (#16155)"}},{"before":"db2a09fa90795a39822a3d349297ecc3d69d6fd2","after":"e33eb82fedc7cc1d9031c68190b4da1052eda3d7","ref":"refs/heads/trunk","pushedAt":"2024-06-01T17:02:03.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-16574 The metrics of LogCleaner disappear after reconfiguration (#15863)\n\nReviewers: Gaurav Narula , Chia-Ping Tsai ","shortMessageHtmlLink":"KAFKA-16574 The metrics of LogCleaner disappear after reconfiguration (…"}},{"before":"fb566e48bf05d749f8db8da803a3570acf25bb11","after":"db2a09fa90795a39822a3d349297ecc3d69d6fd2","ref":"refs/heads/trunk","pushedAt":"2024-06-01T16:56:54.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-16652 add unit test for ClusterTemplate offering zero ClusterConfig (#15862)\n\nReviewers: Chia-Ping Tsai ","shortMessageHtmlLink":"KAFKA-16652 add unit test for ClusterTemplate offering zero ClusterCo…"}},{"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 , Chia-Ping Tsai ","shortMessageHtmlLink":"KAFKA-16639 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 , Jeff Kim , Justine Olshan ","shortMessageHtmlLink":"KAFKA-16864; Optimize uniform (homogenous) assignor (#16088)"}},{"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 , Jeff Kim , Justine Olshan ","shortMessageHtmlLink":"KAFKA-16864; Optimize uniform (homogenous) assignor (#16088)"}},{"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 , Chia-Ping Tsai ","shortMessageHtmlLink":"KAFKA-16639 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 ","shortMessageHtmlLink":"KAFKA-16860; [2/2] Introduce group.version feature flag (#16149)"}},{"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 ","shortMessageHtmlLink":"KAFKA-16860; [2/2] Introduce group.version feature flag (#16149)"}},{"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 ","shortMessageHtmlLink":"KAFKA-16860; [1/2] Introduce group.version feature flag (#16120)"}},{"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 ","shortMessageHtmlLink":"MINOR: update all-latency-avg documentation (#16148)"}},{"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 \r\nReviewers: Mickael Maison ","shortMessageHtmlLink":"KAFKA-16809: Run Javadoc in CI (#16025)"}},{"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 ","shortMessageHtmlLink":"KAFKA-16866 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 ","shortMessageHtmlLink":"MINOR: Refactor DynamicConfig (#16133)"}},{"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 \r\n\r\nReviewers: Mickael Maison , Chia-Ping Tsai ","shortMessageHtmlLink":"MINOR: Bump trunk to 3.9.0-SNAPSHOT (#16150)"}},{"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 ","shortMessageHtmlLink":"KAFKA-16629 Add broker-related tests to ConfigCommandIntegrationTest (#…"}},{"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 ","shortMessageHtmlLink":"KAFKA-16824: 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 , Satish Duggana ","shortMessageHtmlLink":"KAFKA-16866 RemoteLogManagerTest.testCopyQuotaManagerConfig failing (#…"}},{"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 ","shortMessageHtmlLink":"KAFKA-16824: 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":"KAFKA-16766: 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 , Chia-Ping Tsai ","shortMessageHtmlLink":"MINOR: Add more unit tests to LogSegments (#16085)"}}],"hasNextPage":true,"hasPreviousPage":false,"activityType":"all","actor":null,"timePeriod":"all","sort":"DESC","perPage":30,"cursor":"djE6ks8AAAAEWjUlBwA","startCursor":null,"endCursor":null}},"title":"Activity · apache/kafka"}