Skip to content

Commit 9c2603c

Browse files
committed
Merge branch 'kafka-connect' of https://github.com/vasantteja/opentelemetry-java-instrumentation into kafka-connect
2 parents 20c54bf + 339d99f commit 9c2603c

File tree

1 file changed

+8
-1
lines changed

1 file changed

+8
-1
lines changed

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

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -57,7 +57,8 @@
5757
public abstract class KafkaConnectSinkTaskTestBase implements TelemetryRetrieverProvider {
5858

5959
@RegisterExtension
60-
protected static final InstrumentationExtension testing = SmokeTestInstrumentationExtension.create();
60+
protected static final InstrumentationExtension testing =
61+
SmokeTestInstrumentationExtension.create();
6162

6263
protected static final Logger logger = LoggerFactory.getLogger(KafkaConnectSinkTaskTestBase.class);
6364

@@ -94,11 +95,17 @@ public abstract class KafkaConnectSinkTaskTestBase implements TelemetryRetriever
9495

9596
// Abstract methods for database-specific setup
9697
protected abstract void setupDatabaseContainer();
98+
9799
protected abstract void startDatabaseContainer();
100+
98101
protected abstract void stopDatabaseContainer();
102+
99103
protected abstract void clearDatabaseData();
104+
100105
protected abstract String getConnectorInstallCommand();
106+
101107
protected abstract String getConnectorName();
108+
102109
protected abstract String getTopicName();
103110

104111
// Static methods

0 commit comments

Comments
 (0)