Spotless apply

kr-igor · kr-igor · commit f8acfb7cc166 · 2024-03-29T11:43:55.000-05:00
diff --git a/dd-java-agent/instrumentation/kafka-clients-0.11/src/main/java/datadog/trace/instrumentation/kafka_clients/KafkaProducerInstrumentation.java b/dd-java-agent/instrumentation/kafka-clients-0.11/src/main/java/datadog/trace/instrumentation/kafka_clients/KafkaProducerInstrumentation.java
@@ -132,8 +132,8 @@ public static AgentScope onEnter(
         sortedTags.put(TYPE_TAG, "kafka");
         try {
           propagate().inject(span, record.headers(), SETTER);
-          if (STREAMING_CONTEXT.isDisabledForTopic(record.topic()) ||
-              STREAMING_CONTEXT.isSinkTopic(record.topic())) {
+          if (STREAMING_CONTEXT.isDisabledForTopic(record.topic())
+              || STREAMING_CONTEXT.isSinkTopic(record.topic())) {
             // inject the context in the headers, but delay sending the stats until we know the
             // message size.
             // The stats are saved in the pathway context and sent in PayloadSizeAdvice.
@@ -154,8 +154,8 @@ record =
                   record.headers());
 
           propagate().inject(span, record.headers(), SETTER);
-          if (STREAMING_CONTEXT.isDisabledForTopic(record.topic()) ||
-              STREAMING_CONTEXT.isSinkTopic(record.topic())) {
+          if (STREAMING_CONTEXT.isDisabledForTopic(record.topic())
+              || STREAMING_CONTEXT.isSinkTopic(record.topic())) {
             propagate()
                 .injectPathwayContextWithoutSendingStats(
                     span, record.headers(), SETTER, sortedTags);
diff --git a/dd-java-agent/instrumentation/kafka-common/src/main/java/datadog/trace/instrumentation/kafka_common/StreamingContext.java b/dd-java-agent/instrumentation/kafka-common/src/main/java/datadog/trace/instrumentation/kafka_common/StreamingContext.java
@@ -66,8 +66,8 @@ public boolean isSourceTopic(final String topic) {
 
   // Checks if this topic is a part of a streaming topology
   public boolean isDisabledForTopic(final String topic) {
-    return topics.isEmpty() ||
-        Objects.equals(topics.getOrDefault(topic, UNKNOWN_TOPIC), UNKNOWN_TOPIC);
+    return topics.isEmpty()
+        || Objects.equals(topics.getOrDefault(topic, UNKNOWN_TOPIC), UNKNOWN_TOPIC);
   }
 
   private final Set<String> allSourceTopics = ConcurrentHashMap.newKeySet();

Original file line number	Diff line number	Diff line change
`@@ -66,8 +66,8 @@ public boolean isSourceTopic(final String topic) {`
`66`	`66`
`67`	`67`	`// Checks if this topic is a part of a streaming topology`
`68`	`68`	`public boolean isDisabledForTopic(final String topic) {`
`69`		`- return topics.isEmpty() \|\|`
`70`		`- Objects.equals(topics.getOrDefault(topic, UNKNOWN_TOPIC), UNKNOWN_TOPIC);`
	`69`	`+ return topics.isEmpty()`
	`70`	`+ \|\| Objects.equals(topics.getOrDefault(topic, UNKNOWN_TOPIC), UNKNOWN_TOPIC);`
`71`	`71`	`}`
`72`	`72`
`73`	`73`	`private final Set<String> allSourceTopics = ConcurrentHashMap.newKeySet();`