Skip to content

Commit 7338294

Browse files
committed
./gradlew spotlessApply
1 parent fd865c0 commit 7338294

File tree

1 file changed

+3
-2
lines changed
  • instrumentation/kafka/kafka-clients/kafka-clients-common-0.11/library/src/main/java/io/opentelemetry/instrumentation/kafkaclients/common/v0_11/internal

1 file changed

+3
-2
lines changed

instrumentation/kafka/kafka-clients/kafka-clients-common-0.11/library/src/main/java/io/opentelemetry/instrumentation/kafkaclients/common/v0_11/internal/KafkaProcessRequest.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -5,9 +5,9 @@
55

66
package io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal;
77

8+
import javax.annotation.Nullable;
89
import org.apache.kafka.clients.consumer.Consumer;
910
import org.apache.kafka.clients.consumer.ConsumerRecord;
10-
import javax.annotation.Nullable;
1111

1212
/**
1313
* This class is internal and is hence not for public use. Its APIs are unstable and can change at
@@ -17,7 +17,8 @@ public class KafkaProcessRequest extends AbstractKafkaConsumerRequest {
1717

1818
private final ConsumerRecord<?, ?> record;
1919

20-
public static KafkaProcessRequest create(ConsumerRecord<?, ?> record, @Nullable Consumer<?, ?> consumer) {
20+
public static KafkaProcessRequest create(
21+
ConsumerRecord<?, ?> record, @Nullable Consumer<?, ?> consumer) {
2122
return create(record, KafkaUtil.getConsumerGroup(consumer), KafkaUtil.getClientId(consumer));
2223
}
2324

0 commit comments

Comments
 (0)