Skip to content

Commit 15c73d6

Browse files
trasktrask
committed
package name
1 parent acf3c26 commit 15c73d6

File tree

64 files changed

+115
-115
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

64 files changed

+115
-115
lines changed

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

+5-5
Original file line numberDiff line numberDiff line change
@@ -14,11 +14,11 @@
1414
import static net.bytebuddy.matcher.ElementMatchers.takesArgument;
1515
import static net.bytebuddy.matcher.ElementMatchers.takesArguments;
1616

17-
import io.opentelemetry.instrumentation.kafka.internal.KafkaConsumerContext;
18-
import io.opentelemetry.instrumentation.kafka.internal.KafkaConsumerContextUtil;
19-
import io.opentelemetry.instrumentation.kafka.internal.TracingIterable;
20-
import io.opentelemetry.instrumentation.kafka.internal.TracingIterator;
21-
import io.opentelemetry.instrumentation.kafka.internal.TracingList;
17+
import io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.KafkaConsumerContext;
18+
import io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.KafkaConsumerContextUtil;
19+
import io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.TracingIterable;
20+
import io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.TracingIterator;
21+
import io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.TracingList;
2222
import io.opentelemetry.javaagent.extension.instrumentation.TypeInstrumentation;
2323
import io.opentelemetry.javaagent.extension.instrumentation.TypeTransformer;
2424
import java.util.Iterator;

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

+2-2
Original file line numberDiff line numberDiff line change
@@ -16,8 +16,8 @@
1616
import io.opentelemetry.context.Context;
1717
import io.opentelemetry.instrumentation.api.internal.InstrumenterUtil;
1818
import io.opentelemetry.instrumentation.api.internal.Timer;
19-
import io.opentelemetry.instrumentation.kafka.internal.KafkaConsumerContextUtil;
20-
import io.opentelemetry.instrumentation.kafka.internal.KafkaReceiveRequest;
19+
import io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.KafkaConsumerContextUtil;
20+
import io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.KafkaReceiveRequest;
2121
import io.opentelemetry.javaagent.bootstrap.kafka.KafkaClientsConsumerProcessTracing;
2222
import io.opentelemetry.javaagent.extension.instrumentation.TypeInstrumentation;
2323
import io.opentelemetry.javaagent.extension.instrumentation.TypeTransformer;

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

+2-2
Original file line numberDiff line numberDiff line change
@@ -13,8 +13,8 @@
1313

1414
import io.opentelemetry.context.Context;
1515
import io.opentelemetry.context.Scope;
16-
import io.opentelemetry.instrumentation.kafka.internal.KafkaProducerRequest;
17-
import io.opentelemetry.instrumentation.kafka.internal.KafkaPropagation;
16+
import io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.KafkaProducerRequest;
17+
import io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.KafkaPropagation;
1818
import io.opentelemetry.javaagent.bootstrap.Java8BytecodeBridge;
1919
import io.opentelemetry.javaagent.extension.instrumentation.TypeInstrumentation;
2020
import io.opentelemetry.javaagent.extension.instrumentation.TypeTransformer;

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

+4-4
Original file line numberDiff line numberDiff line change
@@ -7,10 +7,10 @@
77

88
import io.opentelemetry.api.GlobalOpenTelemetry;
99
import io.opentelemetry.instrumentation.api.instrumenter.Instrumenter;
10-
import io.opentelemetry.instrumentation.kafka.internal.KafkaInstrumenterFactory;
11-
import io.opentelemetry.instrumentation.kafka.internal.KafkaProcessRequest;
12-
import io.opentelemetry.instrumentation.kafka.internal.KafkaProducerRequest;
13-
import io.opentelemetry.instrumentation.kafka.internal.KafkaReceiveRequest;
10+
import io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.KafkaInstrumenterFactory;
11+
import io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.KafkaProcessRequest;
12+
import io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.KafkaProducerRequest;
13+
import io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.KafkaReceiveRequest;
1414
import io.opentelemetry.javaagent.bootstrap.internal.AgentInstrumentationConfig;
1515
import io.opentelemetry.javaagent.bootstrap.internal.ExperimentalConfig;
1616
import org.apache.kafka.clients.producer.RecordMetadata;

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

+1-1
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,7 @@
99

1010
import io.opentelemetry.context.Context;
1111
import io.opentelemetry.context.Scope;
12-
import io.opentelemetry.instrumentation.kafka.internal.KafkaProducerRequest;
12+
import io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.KafkaProducerRequest;
1313
import org.apache.kafka.clients.producer.Callback;
1414
import org.apache.kafka.clients.producer.RecordMetadata;
1515

‎instrumentation/kafka/kafka-clients/kafka-clients-0.11/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/kafkaclients/v0_11/metrics/KafkaMetricsUtil.java

+3-3
Original file line numberDiff line numberDiff line change
@@ -6,9 +6,9 @@
66
package io.opentelemetry.javaagent.instrumentation.kafkaclients.v0_11.metrics;
77

88
import io.opentelemetry.api.GlobalOpenTelemetry;
9-
import io.opentelemetry.instrumentation.kafka.internal.MetricsReporterList;
10-
import io.opentelemetry.instrumentation.kafka.internal.OpenTelemetryMetricsReporter;
11-
import io.opentelemetry.instrumentation.kafka.internal.OpenTelemetrySupplier;
9+
import io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.MetricsReporterList;
10+
import io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.OpenTelemetryMetricsReporter;
11+
import io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.OpenTelemetrySupplier;
1212
import io.opentelemetry.javaagent.bootstrap.internal.AgentInstrumentationConfig;
1313
import io.opentelemetry.javaagent.bootstrap.internal.DeprecatedConfigProperties;
1414
import java.util.List;

‎instrumentation/kafka/kafka-clients/kafka-clients-0.11/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/kafkaclients/v0_11/KafkaClientDefaultTest.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -9,8 +9,8 @@
99
import static org.assertj.core.api.Assertions.assertThat;
1010

1111
import io.opentelemetry.api.trace.SpanKind;
12-
import io.opentelemetry.instrumentation.kafka.internal.KafkaClientBaseTest;
13-
import io.opentelemetry.instrumentation.kafka.internal.KafkaClientPropagationBaseTest;
12+
import io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.KafkaClientBaseTest;
13+
import io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.KafkaClientPropagationBaseTest;
1414
import io.opentelemetry.instrumentation.testing.junit.AgentInstrumentationExtension;
1515
import io.opentelemetry.instrumentation.testing.junit.InstrumentationExtension;
1616
import io.opentelemetry.sdk.trace.data.LinkData;

‎instrumentation/kafka/kafka-clients/kafka-clients-0.11/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/kafkaclients/v0_11/KafkaClientPropagationDisabledTest.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@
88
import static org.assertj.core.api.Assertions.assertThat;
99

1010
import io.opentelemetry.api.trace.SpanKind;
11-
import io.opentelemetry.instrumentation.kafka.internal.KafkaClientPropagationBaseTest;
11+
import io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.KafkaClientPropagationBaseTest;
1212
import io.opentelemetry.instrumentation.testing.junit.AgentInstrumentationExtension;
1313
import io.opentelemetry.instrumentation.testing.junit.InstrumentationExtension;
1414
import java.time.Duration;

‎instrumentation/kafka/kafka-clients/kafka-clients-0.11/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/kafkaclients/v0_11/KafkaClientSuppressReceiveSpansTest.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -8,8 +8,8 @@
88
import static org.assertj.core.api.Assertions.assertThat;
99

1010
import io.opentelemetry.api.trace.SpanKind;
11-
import io.opentelemetry.instrumentation.kafka.internal.KafkaClientBaseTest;
12-
import io.opentelemetry.instrumentation.kafka.internal.KafkaClientPropagationBaseTest;
11+
import io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.KafkaClientBaseTest;
12+
import io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.KafkaClientPropagationBaseTest;
1313
import io.opentelemetry.instrumentation.testing.junit.AgentInstrumentationExtension;
1414
import io.opentelemetry.instrumentation.testing.junit.InstrumentationExtension;
1515
import java.nio.charset.StandardCharsets;

‎instrumentation/kafka/kafka-clients/kafka-clients-0.11/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/kafkaclients/v0_11/OpenTelemetryMetricsReporterTest.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@
77

88
import static java.util.Collections.emptyMap;
99

10-
import io.opentelemetry.instrumentation.kafka.internal.AbstractOpenTelemetryMetricsReporterTest;
10+
import io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.AbstractOpenTelemetryMetricsReporterTest;
1111
import io.opentelemetry.instrumentation.testing.junit.AgentInstrumentationExtension;
1212
import io.opentelemetry.instrumentation.testing.junit.InstrumentationExtension;
1313
import java.util.Collections;

‎instrumentation/kafka/kafka-clients/kafka-clients-0.11/testing/src/main/java/io/opentelemetry/instrumentation/kafka/internal/AbstractOpenTelemetryMetricsReporterTest.java ‎instrumentation/kafka/kafka-clients/kafka-clients-0.11/testing/src/main/java/io/opentelemetry/instrumentation/kafkaclients/common/v0_11/internal/AbstractOpenTelemetryMetricsReporterTest.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
* SPDX-License-Identifier: Apache-2.0
44
*/
55

6-
package io.opentelemetry.instrumentation.kafka.internal;
6+
package io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal;
77

88
import static java.lang.System.lineSeparator;
99
import static java.util.Comparator.comparing;

‎instrumentation/kafka/kafka-clients/kafka-clients-0.11/testing/src/main/java/io/opentelemetry/instrumentation/kafka/internal/KafkaClientBaseTest.java ‎instrumentation/kafka/kafka-clients/kafka-clients-0.11/testing/src/main/java/io/opentelemetry/instrumentation/kafkaclients/common/v0_11/internal/KafkaClientBaseTest.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
* SPDX-License-Identifier: Apache-2.0
44
*/
55

6-
package io.opentelemetry.instrumentation.kafka.internal;
6+
package io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal;
77

88
import static io.opentelemetry.sdk.testing.assertj.OpenTelemetryAssertions.equalTo;
99
import static io.opentelemetry.sdk.testing.assertj.OpenTelemetryAssertions.satisfies;

‎instrumentation/kafka/kafka-clients/kafka-clients-0.11/testing/src/main/java/io/opentelemetry/instrumentation/kafka/internal/KafkaClientPropagationBaseTest.java ‎instrumentation/kafka/kafka-clients/kafka-clients-0.11/testing/src/main/java/io/opentelemetry/instrumentation/kafkaclients/common/v0_11/internal/KafkaClientPropagationBaseTest.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
* SPDX-License-Identifier: Apache-2.0
44
*/
55

6-
package io.opentelemetry.instrumentation.kafka.internal;
6+
package io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal;
77

88
import static org.assertj.core.api.Assertions.assertThat;
99

‎instrumentation/kafka/kafka-clients/kafka-clients-2.6/library/src/main/java/io/opentelemetry/instrumentation/kafkaclients/v2_6/KafkaTelemetry.java

+11-11
Original file line numberDiff line numberDiff line change
@@ -15,17 +15,17 @@
1515
import io.opentelemetry.instrumentation.api.instrumenter.Instrumenter;
1616
import io.opentelemetry.instrumentation.api.internal.InstrumenterUtil;
1717
import io.opentelemetry.instrumentation.api.internal.Timer;
18-
import io.opentelemetry.instrumentation.kafka.internal.KafkaConsumerContext;
19-
import io.opentelemetry.instrumentation.kafka.internal.KafkaConsumerContextUtil;
20-
import io.opentelemetry.instrumentation.kafka.internal.KafkaHeadersSetter;
21-
import io.opentelemetry.instrumentation.kafka.internal.KafkaProcessRequest;
22-
import io.opentelemetry.instrumentation.kafka.internal.KafkaProducerRequest;
23-
import io.opentelemetry.instrumentation.kafka.internal.KafkaReceiveRequest;
24-
import io.opentelemetry.instrumentation.kafka.internal.KafkaUtil;
25-
import io.opentelemetry.instrumentation.kafka.internal.MetricsReporterList;
26-
import io.opentelemetry.instrumentation.kafka.internal.OpenTelemetryMetricsReporter;
27-
import io.opentelemetry.instrumentation.kafka.internal.OpenTelemetrySupplier;
28-
import io.opentelemetry.instrumentation.kafka.internal.TracingList;
18+
import io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.KafkaConsumerContext;
19+
import io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.KafkaConsumerContextUtil;
20+
import io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.KafkaHeadersSetter;
21+
import io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.KafkaProcessRequest;
22+
import io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.KafkaProducerRequest;
23+
import io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.KafkaReceiveRequest;
24+
import io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.KafkaUtil;
25+
import io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.MetricsReporterList;
26+
import io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.OpenTelemetryMetricsReporter;
27+
import io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.OpenTelemetrySupplier;
28+
import io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.TracingList;
2929
import java.lang.reflect.InvocationTargetException;
3030
import java.lang.reflect.Proxy;
3131
import java.util.Collections;

‎instrumentation/kafka/kafka-clients/kafka-clients-2.6/library/src/main/java/io/opentelemetry/instrumentation/kafkaclients/v2_6/KafkaTelemetryBuilder.java

+4-4
Original file line numberDiff line numberDiff line change
@@ -10,10 +10,10 @@
1010
import com.google.errorprone.annotations.CanIgnoreReturnValue;
1111
import io.opentelemetry.api.OpenTelemetry;
1212
import io.opentelemetry.instrumentation.api.instrumenter.AttributesExtractor;
13-
import io.opentelemetry.instrumentation.kafka.internal.KafkaInstrumenterFactory;
14-
import io.opentelemetry.instrumentation.kafka.internal.KafkaProcessRequest;
15-
import io.opentelemetry.instrumentation.kafka.internal.KafkaProducerRequest;
16-
import io.opentelemetry.instrumentation.kafka.internal.KafkaReceiveRequest;
13+
import io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.KafkaInstrumenterFactory;
14+
import io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.KafkaProcessRequest;
15+
import io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.KafkaProducerRequest;
16+
import io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.KafkaReceiveRequest;
1717
import java.util.ArrayList;
1818
import java.util.Collection;
1919
import java.util.List;

‎instrumentation/kafka/kafka-clients/kafka-clients-2.6/library/src/main/java/io/opentelemetry/instrumentation/kafkaclients/v2_6/TracingConsumerInterceptor.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -10,8 +10,8 @@
1010
import io.opentelemetry.context.Context;
1111
import io.opentelemetry.instrumentation.api.internal.ConfigPropertiesUtil;
1212
import io.opentelemetry.instrumentation.api.internal.Timer;
13-
import io.opentelemetry.instrumentation.kafka.internal.KafkaConsumerContext;
14-
import io.opentelemetry.instrumentation.kafka.internal.KafkaConsumerContextUtil;
13+
import io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.KafkaConsumerContext;
14+
import io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.KafkaConsumerContextUtil;
1515
import java.util.Map;
1616
import java.util.Objects;
1717
import org.apache.kafka.clients.consumer.ConsumerConfig;

‎instrumentation/kafka/kafka-clients/kafka-clients-2.6/library/src/test/java/io/opentelemetry/instrumentation/kafkaclients/v2_6/AbstractInterceptorsTest.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@
77

88
import static org.assertj.core.api.Assertions.assertThat;
99

10-
import io.opentelemetry.instrumentation.kafka.internal.KafkaClientBaseTest;
10+
import io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.KafkaClientBaseTest;
1111
import io.opentelemetry.instrumentation.testing.junit.InstrumentationExtension;
1212
import io.opentelemetry.instrumentation.testing.junit.LibraryInstrumentationExtension;
1313
import java.nio.charset.StandardCharsets;

‎instrumentation/kafka/kafka-clients/kafka-clients-2.6/library/src/test/java/io/opentelemetry/instrumentation/kafkaclients/v2_6/AbstractWrapperTest.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@
88
import static java.util.Collections.singletonList;
99
import static org.assertj.core.api.Assertions.assertThat;
1010

11-
import io.opentelemetry.instrumentation.kafka.internal.KafkaClientBaseTest;
11+
import io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.KafkaClientBaseTest;
1212
import io.opentelemetry.instrumentation.testing.junit.InstrumentationExtension;
1313
import io.opentelemetry.instrumentation.testing.junit.LibraryInstrumentationExtension;
1414
import java.nio.charset.StandardCharsets;

‎instrumentation/kafka/kafka-clients/kafka-clients-2.6/library/src/test/java/io/opentelemetry/instrumentation/kafkaclients/v2_6/internal/OpenTelemetryMetricsReporterTest.java

+3-3
Original file line numberDiff line numberDiff line change
@@ -8,9 +8,9 @@
88
import static org.assertj.core.api.Assertions.assertThat;
99
import static org.assertj.core.api.Assertions.assertThatThrownBy;
1010

11-
import io.opentelemetry.instrumentation.kafka.internal.AbstractOpenTelemetryMetricsReporterTest;
12-
import io.opentelemetry.instrumentation.kafka.internal.OpenTelemetryMetricsReporter;
13-
import io.opentelemetry.instrumentation.kafka.internal.OpenTelemetrySupplier;
11+
import io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.AbstractOpenTelemetryMetricsReporterTest;
12+
import io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.OpenTelemetryMetricsReporter;
13+
import io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.OpenTelemetrySupplier;
1414
import io.opentelemetry.instrumentation.kafkaclients.v2_6.KafkaTelemetry;
1515
import io.opentelemetry.instrumentation.testing.junit.InstrumentationExtension;
1616
import io.opentelemetry.instrumentation.testing.junit.LibraryInstrumentationExtension;

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

+1-1
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
* SPDX-License-Identifier: Apache-2.0
44
*/
55

6-
package io.opentelemetry.instrumentation.kafka.internal;
6+
package io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal;
77

88
import javax.annotation.Nullable;
99

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

+1-1
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
* SPDX-License-Identifier: Apache-2.0
44
*/
55

6-
package io.opentelemetry.instrumentation.kafka.internal;
6+
package io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal;
77

88
import com.google.auto.value.AutoValue;
99

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

+1-1
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
* SPDX-License-Identifier: Apache-2.0
44
*/
55

6-
package io.opentelemetry.instrumentation.kafka.internal;
6+
package io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal;
77

88
import io.opentelemetry.context.Context;
99
import io.opentelemetry.context.propagation.TextMapPropagator;

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

+1-1
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
* SPDX-License-Identifier: Apache-2.0
44
*/
55

6-
package io.opentelemetry.instrumentation.kafka.internal;
6+
package io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal;
77

88
import io.opentelemetry.api.common.AttributeKey;
99
import io.opentelemetry.api.common.AttributesBuilder;

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

+1-1
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
* SPDX-License-Identifier: Apache-2.0
44
*/
55

6-
package io.opentelemetry.instrumentation.kafka.internal;
6+
package io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal;
77

88
import io.opentelemetry.instrumentation.api.incubator.semconv.messaging.MessagingAttributesGetter;
99
import java.nio.charset.StandardCharsets;

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

+1-1
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
* SPDX-License-Identifier: Apache-2.0
44
*/
55

6-
package io.opentelemetry.instrumentation.kafka.internal;
6+
package io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal;
77

88
import com.google.auto.value.AutoValue;
99
import io.opentelemetry.context.Context;

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

+1-1
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
* SPDX-License-Identifier: Apache-2.0
44
*/
55

6-
package io.opentelemetry.instrumentation.kafka.internal;
6+
package io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal;
77

88
import io.opentelemetry.context.Context;
99
import io.opentelemetry.instrumentation.api.util.VirtualField;

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

+1-1
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
* SPDX-License-Identifier: Apache-2.0
44
*/
55

6-
package io.opentelemetry.instrumentation.kafka.internal;
6+
package io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal;
77

88
import static io.opentelemetry.api.common.AttributeKey.longKey;
99

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

+1-1
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
* SPDX-License-Identifier: Apache-2.0
44
*/
55

6-
package io.opentelemetry.instrumentation.kafka.internal;
6+
package io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal;
77

88
import io.opentelemetry.context.propagation.internal.ExtendedTextMapGetter;
99
import java.nio.charset.StandardCharsets;

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

+1-1
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
* SPDX-License-Identifier: Apache-2.0
44
*/
55

6-
package io.opentelemetry.instrumentation.kafka.internal;
6+
package io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal;
77

88
import io.opentelemetry.context.propagation.TextMapSetter;
99
import java.nio.charset.StandardCharsets;

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

+1-1
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
* SPDX-License-Identifier: Apache-2.0
44
*/
55

6-
package io.opentelemetry.instrumentation.kafka.internal;
6+
package io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal;
77

88
import static java.util.Collections.emptyList;
99

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

+3-3
Original file line numberDiff line numberDiff line change
@@ -3,10 +3,10 @@
33
* SPDX-License-Identifier: Apache-2.0
44
*/
55

6-
package io.opentelemetry.instrumentation.kafka.internal;
6+
package io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal;
77

8-
import static io.opentelemetry.instrumentation.kafka.internal.InstrumentDescriptor.INSTRUMENT_TYPE_DOUBLE_OBSERVABLE_COUNTER;
9-
import static io.opentelemetry.instrumentation.kafka.internal.InstrumentDescriptor.INSTRUMENT_TYPE_DOUBLE_OBSERVABLE_GAUGE;
8+
import static io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.InstrumentDescriptor.INSTRUMENT_TYPE_DOUBLE_OBSERVABLE_COUNTER;
9+
import static io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal.InstrumentDescriptor.INSTRUMENT_TYPE_DOUBLE_OBSERVABLE_GAUGE;
1010

1111
import io.opentelemetry.api.common.Attributes;
1212
import io.opentelemetry.api.common.AttributesBuilder;

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

+1-1
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
* SPDX-License-Identifier: Apache-2.0
44
*/
55

6-
package io.opentelemetry.instrumentation.kafka.internal;
6+
package io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal;
77

88
import org.apache.kafka.clients.consumer.Consumer;
99
import org.apache.kafka.clients.consumer.ConsumerRecord;

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

+1-1
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
* SPDX-License-Identifier: Apache-2.0
44
*/
55

6-
package io.opentelemetry.instrumentation.kafka.internal;
6+
package io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal;
77

88
import io.opentelemetry.api.common.AttributeKey;
99
import io.opentelemetry.api.common.AttributesBuilder;

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

+1-1
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
* SPDX-License-Identifier: Apache-2.0
44
*/
55

6-
package io.opentelemetry.instrumentation.kafka.internal;
6+
package io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal;
77

88
import io.opentelemetry.instrumentation.api.incubator.semconv.messaging.MessagingAttributesGetter;
99
import java.nio.charset.StandardCharsets;

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

+1-1
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
* SPDX-License-Identifier: Apache-2.0
44
*/
55

6-
package io.opentelemetry.instrumentation.kafka.internal;
6+
package io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal;
77

88
import java.util.Iterator;
99
import java.util.Map;

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

+1-1
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
* SPDX-License-Identifier: Apache-2.0
44
*/
55

6-
package io.opentelemetry.instrumentation.kafka.internal;
6+
package io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal;
77

88
import io.opentelemetry.api.GlobalOpenTelemetry;
99
import io.opentelemetry.context.Context;

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

+1-1
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
* SPDX-License-Identifier: Apache-2.0
44
*/
55

6-
package io.opentelemetry.instrumentation.kafka.internal;
6+
package io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal;
77

88
import io.opentelemetry.api.common.AttributeKey;
99
import io.opentelemetry.api.common.AttributesBuilder;

0 commit comments

Comments
 (0)