fix test

Author: dao-jun

conventions/src/main/kotlin/otel.java-conventions.gradle.kts

@@ -369,7 +369,7 @@ tasks.withType<Test>().configureEach {
 
   // All tests must complete within 15 minutes.
   // This value is quite big because with lower values (3 mins) we were experiencing large number of false positives
-  timeout.set(Duration.ofMinutes(30))
+  timeout.set(Duration.ofMinutes(15))
 
   develocity.testRetry {
     // You can see tests that were retried by this mechanism in the collected test reports and build scans.

instrumentation/pulsar/pulsar-2.8/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/pulsar/v2_8/TransactionImplInstrumentation.java

@@ -22,7 +22,7 @@
 public class TransactionImplInstrumentation implements TypeInstrumentation {
   @Override
   public ElementMatcher<TypeDescription> typeMatcher() {
-    return named("org.apache.pulsar.client.impl.ProducerImpl");
+    return named("org.apache.pulsar.client.impl.transaction.TransactionImpl");
   }
 
   @Override

instrumentation/pulsar/pulsar-2.8/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/pulsar/v2_8/AbstractPulsarClientTest.java

@@ -88,15 +88,9 @@ static void beforeAll() throws PulsarClientException {
     pulsar =
         new PulsarContainer(DEFAULT_IMAGE_NAME)
             .withEnv("PULSAR_MEM", "-Xmx128m")
-            .withEnv("PULSAR_PREFIX_transactionCoordinatorEnabled", "true")
-            .withEnv(
-                "PULSAR_PREFIX_transactionMetadataStoreProviderClassName",
-                "org.apache.pulsar.transaction.coordinator.impl.InMemTransactionMetadataStoreProvider")
-            .withEnv(
-                "PULSAR_PREFIX_transactionBufferProviderClassName",
-                "org.apache.pulsar.broker.transaction.buffer.impl.InMemTransactionBufferProvider")
             .withLogConsumer(new Slf4jLogConsumer(logger))
-            .withStartupTimeout(Duration.ofMinutes(2));
+            .withStartupTimeout(Duration.ofMinutes(2))
+            .withTransactions();
     pulsar.start();
 
     brokerHost = pulsar.getHost();