[#10407] Found some issue , when i using kafka consume, with kafka-coroutine context

.github/workflows/maven.yml

@@ -5,9 +5,9 @@ name: Maven
 
 on:
   push:
-    branches: [ master, 2.3.x ]
+    branches: [ master ]
   pull_request:
-    branches: [ master, 2.3.x ]
+    branches: [ master ]
 
 jobs:
 

README.md

@@ -5,12 +5,12 @@
 [![Maven](https://img.shields.io/github/actions/workflow/status/pinpoint-apm/pinpoint/maven.yml?branch=master&label=build&logo=github)](https://github.com/pinpoint-apm/pinpoint/actions?query=workflow%3AMaven)
 [![codecov](https://codecov.io/gh/pinpoint-apm/pinpoint/branch/master/graph/badge.svg)](https://codecov.io/gh/pinpoint-apm/pinpoint)
 
-## Latest Release (2023/06/14)
+## Latest Release (2023/10/10)
 
-We're happy to announce the release of Pinpoint v2.5.2.
-Please check the release note at (https://github.com/pinpoint-apm/pinpoint/releases/tag/v2.5.2).
+We're happy to announce the release of Pinpoint v2.5.3.
+Please check the release note at (https://github.com/pinpoint-apm/pinpoint/releases/tag/v2.5.3).
 
-The current stable version is [v2.5.2](https://github.com/pinpoint-apm/pinpoint/releases/tag/v2.5.2).
+The current stable version is [v2.5.3](https://github.com/pinpoint-apm/pinpoint/releases/tag/v2.5.3).
 
 ## Live Demo
 

agent-testweb/closed-module-testlib/pom.xml

@@ -0,0 +1,33 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>com.navercorp.pinpoint</groupId>
+        <artifactId>pinpoint-agent-testweb</artifactId>
+        <version>2.6.0-SNAPSHOT</version>
+    </parent>
+
+    <artifactId>pinpoint-closed-module-testlib</artifactId>
+    <packaging>jar</packaging>
+
+    <properties>
+        <jdk.version>11</jdk.version>
+        <jdk.home>${env.JAVA_11_HOME}</jdk.home>
+    </properties>
+
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <configuration>
+                    <source>11</source>
+                    <target>11</target>
+                </configuration>
+            </plugin>
+        </plugins>
+    </build>
+
+</project>

agent-testweb/closed-module-testlib/src/main/java/com/navercorp/pinpointdemo/ClosedService.java

@@ -0,0 +1,48 @@
+/*
+ * Copyright 2023 NAVER Corp.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.navercorp.pinpointdemo;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+
+/**
+ * @author youngjin.kim2
+ */
+public class ClosedService {
+
+    private final ExecutorService executor = Executors.newFixedThreadPool(4);
+
+    public void fire() {
+        try {
+            List<Integer> data = new ArrayList<>(16);
+            for (int i = 0; i < 16; i++) {
+                data.add(i);
+            }
+            data.parallelStream()
+                    .map(v -> parserTask(v))
+                    .forEach(this.executor::submit);
+        } catch (Exception ignored) {
+            System.out.println("error");
+        }
+    }
+
+    private Runnable parserTask(int v) {
+        return () -> System.out.println(v + "^2=" + (v*v));
+    }
+
+}

agent-testweb/closed-module-testlib/src/main/java/module-info.java

@@ -0,0 +1,3 @@
+module pinpoint.closed.module.testlib {
+    exports com.navercorp.pinpointdemo;
+}

agent-testweb/closed-module-testweb/pom.xml

@@ -0,0 +1,54 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>com.navercorp.pinpoint</groupId>
+        <artifactId>pinpoint-agent-testweb</artifactId>
+        <version>2.6.0-SNAPSHOT</version>
+    </parent>
+
+    <artifactId>pinpoint-closed-module-testweb</artifactId>
+    <packaging>jar</packaging>
+
+    <properties>
+        <pinpoint.agent.jvmargument>
+            ${pinpoint.agent.default.jvmargument}
+        </pinpoint.agent.jvmargument>
+        <curator.framework.version>4.2.0</curator.framework.version>
+
+        <jdk.version>11</jdk.version>
+        <jdk.home>${env.JAVA_11_HOME}</jdk.home>
+    </properties>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>com.navercorp.pinpoint</groupId>
+            <artifactId>pinpoint-closed-module-testlib</artifactId>
+            <version>${project.version}</version>
+        </dependency>
+    </dependencies>
+
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+            </plugin>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <configuration>
+                    <source>11</source>
+                    <target>11</target>
+                </configuration>
+            </plugin>
+        </plugins>
+    </build>
+
+</project>

agent-testweb/closed-module-testweb/src/main/java/com/navercorp/pinpoint/closedcaller/ClosedClassCallerStarter.java

@@ -0,0 +1,31 @@
+/*
+ * Copyright 2023 NAVER Corp.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.navercorp.pinpoint.closedcaller;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+/**
+ * @author youngjin.kim2
+ */
+@SpringBootApplication
+public class ClosedClassCallerStarter {
+
+    public static void main(String[] args) {
+        SpringApplication.run(ClosedClassCallerStarter.class, args);
+    }
+
+}

agent-testweb/closed-module-testweb/src/main/java/com/navercorp/pinpoint/closedcaller/ClosedClassCallingController.java

@@ -0,0 +1,36 @@
+/*
+ * Copyright 2023 NAVER Corp.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.navercorp.pinpoint.closedcaller;
+
+import com.navercorp.pinpointdemo.ClosedService;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * @author youngjin.kim2
+ */
+@RestController
+public class ClosedClassCallingController {
+
+    private final ClosedService closedService = new ClosedService();
+
+    @GetMapping("/closed")
+    public String callClosedMethod() {
+        this.closedService.fire();
+        return "called";
+    }
+
+}

agent-testweb/closed-module-testweb/src/main/java/module-info.java

@@ -0,0 +1,10 @@
+open module com.navercorp.pinpoint.closedcaller {
+    requires spring.web;
+    requires spring.context;
+    requires spring.beans;
+    requires spring.boot.autoconfigure;
+    requires spring.boot;
+    requires spring.core;
+
+    requires pinpoint.closed.module.testlib;
+}

agent-testweb/pom.xml

@@ -82,6 +82,8 @@
         <module>ning-asynchttpclient-plugin-testweb</module>
         <module>okhttp-plugin-testweb</module>
         <module>grpc-plugin-testweb</module>
+        <module>closed-module-testweb</module>
+        <module>closed-module-testlib</module>
     </modules>
 
     <dependencyManagement>

agent-testweb/reactor-plugin-testweb/pom.xml

@@ -29,6 +29,10 @@
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-autoconfigure</artifactId>
         </dependency>
+        <dependency>
+            <groupId>com.navercorp.pinpoint</groupId>
+            <artifactId>pinpoint-agent-testweb-commons</artifactId>
+        </dependency>
     </dependencies>
 
     <build>