This is an automated email from the ASF dual-hosted git repository.
mittal pushed a commit to branch 4.0
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/4.0 by this push:
new 26e5a53906b HOTFIX: Correcting build after cherry-pick (#19969)
26e5a53906b is described below
commit 26e5a53906ba04721b9f5435632d3c8b4a6a8ece
Author: Apoorv Mittal <[email protected]>
AuthorDate: Mon Jun 16 10:11:18 2025 +0100
HOTFIX: Correcting build after cherry-pick (#19969)
Fixing build after cherrypicking:
```
commit 254c1fa519b37bddc2488e80979406129fd56808
Author: Apoorv Mittal <[email protected]>
Date: Thu Jun 12 22:52:50 2025 +0100
MINOR: Fixing client telemetry validate request (#19959)
Minor fix to correct the validate condition for GetTelemetryRequests.
Added respective tests as well.
Reviewers: Andrew Schofield <[email protected]>
```
Reviewers: Manikumar Reddy <[email protected]>
---
.../test/java/org/apache/kafka/server/ClientMetricsManagerTest.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/server/src/test/java/org/apache/kafka/server/ClientMetricsManagerTest.java
b/server/src/test/java/org/apache/kafka/server/ClientMetricsManagerTest.java
index ad6134a4685..55eed0c1977 100644
--- a/server/src/test/java/org/apache/kafka/server/ClientMetricsManagerTest.java
+++ b/server/src/test/java/org/apache/kafka/server/ClientMetricsManagerTest.java
@@ -1125,7 +1125,7 @@ public class ClientMetricsManagerTest {
@Test
public void
testGetTelemetrySubscriptionAfterPushTelemetryUnknownSubscriptionSucceeds()
throws Exception {
- clientMetricsManager.updateSubscription("sub-1",
ClientMetricsTestUtils.defaultTestProperties());
+ clientMetricsManager.updateSubscription("sub-1",
ClientMetricsTestUtils.defaultProperties());
assertEquals(1, clientMetricsManager.subscriptions().size());
GetTelemetrySubscriptionsRequest subscriptionsRequest = new
GetTelemetrySubscriptionsRequest.Builder(
@@ -1163,7 +1163,7 @@ public class ClientMetricsManagerTest {
@Test
public void
testGetTelemetrySubscriptionAfterPushTelemetryUnknownCompressionSucceeds()
throws Exception {
- clientMetricsManager.updateSubscription("sub-1",
ClientMetricsTestUtils.defaultTestProperties());
+ clientMetricsManager.updateSubscription("sub-1",
ClientMetricsTestUtils.defaultProperties());
assertEquals(1, clientMetricsManager.subscriptions().size());
GetTelemetrySubscriptionsRequest subscriptionsRequest = new
GetTelemetrySubscriptionsRequest.Builder(
