Skip to content

Commit ad96d68

Browse files
committed
Update Kafka Connect base test plumbing
1 parent 0118257 commit ad96d68

1 file changed

Lines changed: 3 additions & 0 deletions

File tree

instrumentation/kafka/kafka-connect-2.6/testing/src/test/java/io/opentelemetry/instrumentation/kafkaconnect/v2_6/KafkaConnectSinkTaskBaseTest.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -275,6 +275,9 @@ private void setupKafkaConnect() {
275275
.withEnv("OTEL_BSP_MAX_EXPORT_BATCH_SIZE", "1")
276276
.withEnv("OTEL_BSP_SCHEDULE_DELAY", "10ms")
277277
.withEnv("OTEL_METRIC_EXPORT_INTERVAL", "1000")
278+
.withEnv(
279+
"OTEL_SEMCONV_STABILITY_OPT_IN",
280+
System.getProperty("otel.semconv-stability.opt-in"))
278281
.withEnv("CONNECT_BOOTSTRAP_SERVERS", getInternalKafkaBoostrapServers())
279282
.withEnv("CONNECT_REST_ADVERTISED_HOST_NAME", KAFKA_CONNECT_NETWORK_ALIAS)
280283
.withEnv("CONNECT_PLUGIN_PATH", PLUGIN_PATH_CONTAINER)

0 commit comments

Comments
 (0)