Alex li

Cannot resolve bytebuddy otel class when using a second Java Agent with ByteBuddy for Kafka instrumentation

2

I'm encountering a net.bytebuddy.pool.TypePool$Resolution$NoSuchTypeException when using a custom Java Agent based on ByteBuddy in conjunction with the OpenTelemetry Java Agent. The error occurs during transformation of KafkaConsumer: ``` Failed to...

kafka ban consumer plug-in resubscribe will override ConsumerRebalanceListener

1

### What happened? 1. In Kafka, the mechanism to disable and restore consumption is implemented through resubscription. However, in the KafkaConsumerController#disableConsumption method, the resubscription is directly implemented via kafkaConsumer.subscribe(subtractTopics), which...

PluginClassLoader local ClassLoader疑问

2

### What do you want to ask? 您好，看了这边文章：https://developer.huawei.com/consumer/cn/forum/topic/0208129550716548036 有些疑惑，请教一下ClassLoader问题。 文章中说在执行Sermant Aspect前后去设置并清除localLoader，但是看源码并不是执行拦截方法时设置的，而是创建时候设置的（看的是2.0.0版本的源码），不知道是不是我理解错误。 Interceptor在创建时使用setLocalLoader设置了临时local ClassLoader，创建结束进行清空，这个没什么问题。但是当运行interceptor 的before、after等方法时，需要加载业务class，但是此时local loader为空，只能从Thread.currentThread().getContextClassLoader()去加载业务的class，但是有些场景（比如jdk17 ForkJoinPool Thread ContextLoader为SystemClassLoader并非spring ClassLoader），会出现加载失败，请问这种情况框架层面有解决吗，是怎么解决的？