Skip to content

Commit 49c0831

Browse files
committed
spotless
1 parent 7a2c2e9 commit 49c0831

File tree

2 files changed

+3
-6
lines changed

2 files changed

+3
-6
lines changed

instrumentation/kafka/kafka-streams-0.11/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/kafkastreams/KafkaStreamsDefaultTest.java

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -240,8 +240,7 @@ void testKafkaProduceAndConsumeWithStreamsInBetween()
240240
if (Boolean.getBoolean("testLatestDeps")) {
241241
assertions.add(
242242
equalTo(
243-
MessagingIncubatingAttributes.MESSAGING_KAFKA_CONSUMER_GROUP,
244-
"test"));
243+
MessagingIncubatingAttributes.MESSAGING_KAFKA_CONSUMER_GROUP, "test"));
245244
}
246245
span.hasName(STREAM_PROCESSED + " receive")
247246
.hasKind(SpanKind.CONSUMER)
@@ -278,8 +277,7 @@ void testKafkaProduceAndConsumeWithStreamsInBetween()
278277
if (Boolean.getBoolean("testLatestDeps")) {
279278
assertions.add(
280279
equalTo(
281-
MessagingIncubatingAttributes.MESSAGING_KAFKA_CONSUMER_GROUP,
282-
"test"));
280+
MessagingIncubatingAttributes.MESSAGING_KAFKA_CONSUMER_GROUP, "test"));
283281
}
284282
span.hasName(STREAM_PROCESSED + " process")
285283
.hasKind(SpanKind.CONSUMER)

instrumentation/kafka/kafka-streams-0.11/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/kafkastreams/KafkaStreamsSuppressReceiveSpansTest.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -209,8 +209,7 @@ void testKafkaProduceAndConsumeWithStreamsInBetween()
209209
if (Boolean.getBoolean("testLatestDeps")) {
210210
assertions.add(
211211
equalTo(
212-
MessagingIncubatingAttributes.MESSAGING_KAFKA_CONSUMER_GROUP,
213-
"test"));
212+
MessagingIncubatingAttributes.MESSAGING_KAFKA_CONSUMER_GROUP, "test"));
214213
}
215214
span.hasName(STREAM_PROCESSED + " process")
216215
.hasKind(SpanKind.CONSUMER)

0 commit comments

Comments
 (0)