wip: removed the unwanted dependencies and assertions from tests.

Author: vasantteja

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

@@ -421,113 +421,6 @@ public void testKafkaConnectMongoSinkTaskInstrumentation()
 
     assertThat(foundKafkaConnectSpan).as("Should find Kafka Connect span").isTrue();
 
-    // Note: MongoDB spans are NOT expected from the Kafka Connect integration because
-    // the MongoDB Kafka Connector creates its own MongoDB client without TracingCommandListener
-    // See:
-    // https://github.com/mongodb/mongo-kafka/blob/master/src/main/java/com/mongodb/kafka/connect/sink/StartedMongoSinkTask.java
-    // This demonstrates that trace propagation depends on how connectors integrate with
-    // instrumented libraries.
-    //
-    // Unlike JDBC Kafka Connector (which uses instrumented PreparedStatement operations),
-    // MongoDB Kafka Connector bypasses OpenTelemetry instrumentation, so we only get
-    // the Kafka Connect span with span links to producers.
-    logger.info(
-        "MongoDB span found: {} (expected: false for Kafka Connect integration)", foundMongoSpan);
-    logger.info(
-        "Parent-child relationship found: {} (expected: false for Kafka Connect integration)",
-        foundParentChildRelationship);
-
-    // The separate testTracePropagationWithInstrumentedMongoDB() demonstrates that
-    // MongoDB instrumentation works perfectly when properly configured
-
-  }
-
-  @Test
-  public void testTracePropagationWithInstrumentedMongoDB() throws Exception {
-    logger.info("=== Testing Trace Propagation with Properly Instrumented MongoDB ===");
-
-    // Create a properly instrumented MongoDB client (this will have TracingCommandListener)
-    String mongoConnectionString =
-        String.format(
-            Locale.ROOT, "mongodb://%s:%d", mongoDB.getHost(), mongoDB.getMappedPort(27017));
-
-    try (com.mongodb.client.MongoClient instrumentedClient =
-        com.mongodb.client.MongoClients.create(mongoConnectionString)) {
-
-      // Get the collection
-      com.mongodb.client.MongoCollection<org.bson.Document> collection =
-          instrumentedClient.getDatabase("test").getCollection("demo");
-
-      // Clear spans from backend to isolate our test
-      clearBackendTraces();
-
-      // Perform a MongoDB operation - this should create a span with proper instrumentation
-      org.bson.Document doc =
-          new org.bson.Document("demo", "trace-propagation-test")
-              .append("timestamp", System.currentTimeMillis());
-      collection.insertOne(doc);
-
-      // Wait for spans to arrive
-      Thread.sleep(1000);
-
-      // Check if MongoDB span was created
-      String backendUrl = getBackendUrl();
-      String tracesJson =
-          given()
-              .when()
-              .get(backendUrl + "/get-traces")
-              .then()
-              .statusCode(200)
-              .extract()
-              .asString();
-
-      if (!tracesJson.equals("[]")) {
-        logger.info("✅ SUCCESS: MongoDB operation created spans with proper instrumentation!");
-        logger.info(
-            "This proves that trace propagation works when downstream systems are properly instrumented.");
-
-        // Parse and verify MongoDB spans
-        ObjectMapper objectMapper = new ObjectMapper();
-        JsonNode tracesNode = objectMapper.readTree(tracesJson);
-
-        boolean foundMongoSpan = false;
-        for (JsonNode trace : tracesNode) {
-          JsonNode resourceSpans = trace.get("resourceSpans");
-          if (resourceSpans != null && resourceSpans.isArray()) {
-            for (JsonNode resourceSpan : resourceSpans) {
-              JsonNode scopeSpans = resourceSpan.get("scopeSpans");
-              if (scopeSpans != null && scopeSpans.isArray()) {
-                for (JsonNode scopeSpan : scopeSpans) {
-                  JsonNode spans = scopeSpan.get("spans");
-                  if (spans != null && spans.isArray()) {
-                    for (JsonNode span : spans) {
-                      JsonNode nameNode = span.get("name");
-                      if (nameNode != null) {
-                        String spanName = nameNode.asText();
-                        if (spanName.contains("insert")) {
-                          foundMongoSpan = true;
-                          logger.info("Found MongoDB span: {}", spanName);
-                        }
-                      }
-                    }
-                  }
-                }
-              }
-            }
-          }
-        }
-
-        assertThat(foundMongoSpan)
-            .as("Should find MongoDB span when using properly instrumented client")
-            .isTrue();
-
-      } else {
-        logger.info(
-            "ℹ️  No spans captured - this may indicate MongoDB instrumentation is not active");
-        // Don't fail the test - this demonstrates the difference between instrumented and
-        // non-instrumented clients
-      }
-    }
   }
 
   // Private methods

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

@@ -443,37 +443,7 @@ public void testKafkaConnectSinkTaskInstrumentation() throws IOException, Interr
     assertThat(spanCount).as("Should find at least one span").isGreaterThan(0);
 
     assertThat(foundKafkaConnectSpan).as("Should find Kafka Connect span").isTrue();
-
-    // JDBC spans are created by the instrumentation, as confirmed by container logs.
-    // However, in this test environment, we may see spans from both:
-    // 1. Test setup operations (CREATE TABLE, SELECT COUNT(*) - no parent-child relationship)
-    // 2. Actual Kafka Connect container operations (with perfect parent-child relationships)
-    //
-    // Container logs show perfect trace propagation: Producer → Kafka Connect → JDBC operations
-    // But test environment may only capture the test-related JDBC spans, not container spans.
-    assertThat(foundJdbcSpan)
-        .as("Should find JDBC spans - JDBC instrumentation is active")
-        .isTrue();
-
-    logger.info("JDBC instrumentation test result: JDBC spans were found");
-
-    // Parent-child relationships depend on the span source:
-    // - Container spans (actual Kafka Connect operations): Perfect parent-child relationships ✅
-    // - Test environment spans (test setup): No parent-child relationships ❌
-    //
-    // The container logs prove that trace propagation works perfectly when both
-    // instrumentations run in the same JVM process.
-    if (foundParentChildRelationship) {
-      logger.info(
-          "✅ SUCCESS: Parent-child relationship found - complete trace propagation verified!");
-    } else {
-      logger.info(
-          "ℹ️  No parent-child relationship in test spans (expected for cross-process scenario)");
-      logger.info(
-          "📋 Container logs confirm perfect trace propagation: Producer → Kafka Connect → Database");
-      logger.info(
-          "🎯 This demonstrates the instrumentation works correctly for same-JVM deployments");
-    }
+   
   }
 
   @AfterAll
@@ -584,14 +554,6 @@ private static void setupSinkConnector(String topicName) throws IOException {
         .then()
         .log()
         .all();
-
-    // Remove this problematic cleanup code:
-    // try (AdminClient adminClient = createAdminClient()) {
-    //     adminClient.deleteTopics(Collections.singletonList(TOPIC_NAME)).all().get();
-    //     logger.info("Deleted existing topic: " + TOPIC_NAME);
-    // } catch (e instanceof InterruptedException) {
-    //     logger.info("Topic cleanup: " + e.getMessage());
-    // }
   }
 
   private static void produceMessagesToKafka(String topicName) {

javaagent/build.gradle.kts

@@ -94,7 +94,6 @@ dependencies {
   baseJavaagentLibs(project(":instrumentation:opentelemetry-api:opentelemetry-api-1.52:javaagent"))
   baseJavaagentLibs(project(":instrumentation:opentelemetry-instrumentation-api:javaagent"))
   baseJavaagentLibs(project(":instrumentation:kafka:kafka-connect-2.6:javaagent"))
-  baseJavaagentLibs(project(":instrumentation:jdbc:javaagent"))
   baseJavaagentLibs(project(":instrumentation:opentelemetry-instrumentation-annotations-1.16:javaagent"))
   baseJavaagentLibs(project(":instrumentation:executors:javaagent"))
   baseJavaagentLibs(project(":instrumentation:internal:internal-application-logger:javaagent"))