Skip to content

Commit 34851ce

Browse files
committed
./gradlew spotlessApply
1 parent da485fd commit 34851ce

File tree

3 files changed

+10
-4
lines changed

3 files changed

+10
-4
lines changed

instrumentation/kafka/kafka-clients/kafka-clients-0.11/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/kafkaclients/v0_11/ConsumerRecordsInstrumentation.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -146,7 +146,10 @@ public static <K, V> void wrap(
146146
KafkaConsumerContext consumerContext = KafkaConsumerContextUtil.get(records);
147147
listIterator =
148148
TracingListIterator.wrap(
149-
listIterator, consumerProcessInstrumenter(), wrappingEnabledSupplier(), consumerContext);
149+
listIterator,
150+
consumerProcessInstrumenter(),
151+
wrappingEnabledSupplier(),
152+
consumerContext);
150153
}
151154
}
152155
}

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

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -137,12 +137,14 @@ public int lastIndexOf(Object o) {
137137

138138
@Override
139139
public ListIterator<ConsumerRecord<K, V>> listIterator() {
140-
return TracingListIterator.wrap(delegate.listIterator(), instrumenter, wrappingEnabled, consumerContext);
140+
return TracingListIterator.wrap(
141+
delegate.listIterator(), instrumenter, wrappingEnabled, consumerContext);
141142
}
142143

143144
@Override
144145
public ListIterator<ConsumerRecord<K, V>> listIterator(int index) {
145-
return TracingListIterator.wrap(delegate.listIterator(index), instrumenter, wrappingEnabled, consumerContext);
146+
return TracingListIterator.wrap(
147+
delegate.listIterator(index), instrumenter, wrappingEnabled, consumerContext);
146148
}
147149

148150
@Override

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

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,8 @@ private TracingListIterator(
2626
BooleanSupplier wrappingEnabled,
2727
KafkaConsumerContext consumerContext) {
2828
this.delegateListIterator = delegateListIterator;
29-
this.tracingIterator = TracingIterator.wrap(delegateListIterator, instrumenter, wrappingEnabled, consumerContext);
29+
this.tracingIterator =
30+
TracingIterator.wrap(delegateListIterator, instrumenter, wrappingEnabled, consumerContext);
3031
}
3132

3233
public static <K, V> ListIterator<ConsumerRecord<K, V>> wrap(

0 commit comments

Comments
 (0)