Skip to content

Commit cf58acf

Browse files
committed
update based on spotlessApply
1 parent 35550b0 commit cf58acf

File tree

2 files changed

+23
-23
lines changed

2 files changed

+23
-23
lines changed

kafka-exporter/src/main/java/io/opentelemetry/contrib/kafka/KafkaSpanExporter.java

Lines changed: 22 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -59,25 +59,28 @@ public CompletableResultCode export(@Nonnull Collection<SpanData> spans) {
5959

6060
CompletableResultCode result = new CompletableResultCode();
6161
CompletableFuture.runAsync(
62-
() ->
63-
producer.send(
64-
producerRecord,
65-
(metadata, exception) -> {
66-
if (exception == null) {
67-
result.succeed();
68-
} else {
69-
logger.error(
70-
String.format("Error while sending spans to Kafka topic %s", topicName),
71-
exception);
72-
result.fail();
73-
}
74-
}),
75-
executorService).whenComplete((ignore, exception) -> {
76-
if (exception != null) {
77-
logger.error("Executor task failed while sending to Kafka topic {}", topicName, exception);
78-
result.fail();
79-
}
80-
});
62+
() ->
63+
producer.send(
64+
producerRecord,
65+
(metadata, exception) -> {
66+
if (exception == null) {
67+
result.succeed();
68+
} else {
69+
logger.error(
70+
String.format("Error while sending spans to Kafka topic %s", topicName),
71+
exception);
72+
result.fail();
73+
}
74+
}),
75+
executorService)
76+
.whenComplete(
77+
(ignore, exception) -> {
78+
if (exception != null) {
79+
logger.error(
80+
"Executor task failed while sending to Kafka topic {}", topicName, exception);
81+
result.fail();
82+
}
83+
});
8184
return result;
8285
}
8386

kafka-exporter/src/test/java/io/opentelemetry/contrib/kafka/KafkaSpanExporterIntegrationTest.java

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -163,10 +163,7 @@ void exportWhenProducerFailsToSend() {
163163
var mockProducer = new MockProducer<String, Collection<SpanData>>();
164164
mockProducer.sendException = new KafkaException("Simulated kafka exception");
165165
var testSubjectWithMockProducer =
166-
KafkaSpanExporter.newBuilder()
167-
.setTopicName(TOPIC)
168-
.setProducer(mockProducer)
169-
.build();
166+
KafkaSpanExporter.newBuilder().setTopicName(TOPIC).setProducer(mockProducer).build();
170167

171168
ImmutableList<SpanData> spans =
172169
ImmutableList.of(makeBasicSpan("span-1"), makeBasicSpan("span-2"));

0 commit comments

Comments
 (0)