From c0d423ecdb1d75ba26d177d4ac10d48ed5b3fcdf Mon Sep 17 00:00:00 2001 From: "A. Sophie Blee-Goldman" Date: Thu, 21 Nov 2024 21:37:35 -0800 Subject: [PATCH] checkstyle --- .../java/dev/responsive/examples/common/E2ETestUtils.java | 8 ++++---- .../examples/regression/tests/STJoinExample.java | 3 ++- 2 files changed, 6 insertions(+), 5 deletions(-) diff --git a/kafka-client-examples/e2e-test/src/main/java/dev/responsive/examples/common/E2ETestUtils.java b/kafka-client-examples/e2e-test/src/main/java/dev/responsive/examples/common/E2ETestUtils.java index 334849f9..b3ac53fd 100644 --- a/kafka-client-examples/e2e-test/src/main/java/dev/responsive/examples/common/E2ETestUtils.java +++ b/kafka-client-examples/e2e-test/src/main/java/dev/responsive/examples/common/E2ETestUtils.java @@ -142,16 +142,16 @@ public static void maybeCreateKeyspace(final Map properties) { errorDetails.put("exceptionType", e.getClass().getName()); if (e instanceof AllNodesFailedException) { final Map> allErrors = ((AllNodesFailedException) e).getAllErrors(); - int node_i = 1; + int nodeIdx = 1; for (final var node : allErrors.entrySet()) { - final String nodeId = "node-" + node_i; + final String nodeId = "node-" + nodeIdx; errorDetails.put(nodeId + "_endPoint", node.getKey().getEndPoint().asMetricPrefix()); final var nodeErrors = node.getValue(); LOG.error("All errors for node at {}: {}", nodeId, nodeErrors); - int error_i = 1; + int errorIdx = 1; for (final var error : nodeErrors) { - errorDetails.put(nodeId + "_err-" + error_i, error.getMessage()); + errorDetails.put(nodeId + "_err-" + errorIdx, error.getMessage()); } } Assert.unreachable(errorMessage, errorDetails); diff --git a/kafka-client-examples/e2e-test/src/main/java/dev/responsive/examples/regression/tests/STJoinExample.java b/kafka-client-examples/e2e-test/src/main/java/dev/responsive/examples/regression/tests/STJoinExample.java index 088c4b26..3b211634 100644 --- a/kafka-client-examples/e2e-test/src/main/java/dev/responsive/examples/regression/tests/STJoinExample.java +++ b/kafka-client-examples/e2e-test/src/main/java/dev/responsive/examples/regression/tests/STJoinExample.java @@ -88,7 +88,8 @@ protected Topology buildTopology() { }) .groupByKey() .windowedBy(TimeWindows.ofSizeAndGrace(Duration.ofDays(1), Duration.ofHours(12))) - .reduce(EnrichedOrder::combineWith, Materialized.with(Serdes.String(), RegressionSchema.enrichedOrderSerde())) + .reduce(EnrichedOrder::combineWith, + Materialized.with(Serdes.String(), RegressionSchema.enrichedOrderSerde())) .toStream() .selectKey((w, v) -> w.key()) .to(