Error when trying to modify the response of a method assigned to a public static final config variable

[jwalor]

jdk corretto-17.0.7 , and bytebuddy version is 1.14.9

I get :

None of [public static java.lang.Object com.bcp.fraud.streams.Main$MyInterceptor.intercept(com.bcp.fraud.streams.Main$MyCallable,java.lang.Object[]) throws java.lang.Exception] allows for delegation from public static org.apache.kafka.common.config.ConfigDef io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig.baseSchemaRegistryConfigDef()

this is my code:

new AgentBuilder.Default()
.with(AgentBuilder.RedefinitionStrategy.RETRANSFORMATION) .with(AgentBuilder.TypeStrategy.Default.REDEFINE) .with(new FlowListener())
.ignore(nameStartsWith("net.bytebuddy."))
.type(ElementMatchers.named("io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig"))
.transform((builder, typeDescription, classLoader, module, protectionDomain) -> { //return builder; return builder
.method(named("baseSchemaRegistryConfigDef")) .intercept(MethodDelegation.to(MyInterceptor.class));
}) .installOn(inst);

What I want is to modify a routine of that method in Java, what should I use?

I use net.bytebuddy.agent.ByteBuddyAgent.install method to instrumentation at runtime.

[raphw]

What's your interceptor class, including annotations and imports?

[jwalor]

Hi , thanks for replying, Is it technically possible to modify this method?

--> Code: `import io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig; import io.confluent.rest.RestConfigException; import javassist.NotFoundException; import net.bytebuddy.agent.ByteBuddyAgent; import net.bytebuddy.agent.builder.AgentBuilder; import net.bytebuddy.asm.MemberSubstitution; import net.bytebuddy.description.type.TypeDescription; import net.bytebuddy.dynamic.DynamicType; import net.bytebuddy.matcher.ElementMatchers; import net.bytebuddy.utility.JavaModule; import org.apache.kafka.common.config.ConfigDef;

import java.lang.instrument.Instrumentation; import java.security.ProtectionDomain; import java.util.Properties; import static net.bytebuddy.matcher.ElementMatchers.*;

public class MainX2 {

public static void main(String[] args) throws RestConfigException, NotFoundException {
    SchemaRegistryConfig test = new SchemaRegistryConfig(new Properties());
    Instrumentation instrumentation = ByteBuddyAgent.install();
    new AgentBuilder.Default()
            .with(AgentBuilder.RedefinitionStrategy.RETRANSFORMATION)
            .with(AgentBuilder.RedefinitionStrategy.REDEFINITION)
            .with(AgentBuilder.RedefinitionStrategy.Listener.StreamWriting.toSystemError())
            .with(AgentBuilder.Listener.StreamWriting.toSystemError().withTransformationsOnly())
            .with(AgentBuilder.InstallationListener.StreamWriting.toSystemError())
            .type(ElementMatchers.named("io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig"))
            .transform(new AgentBuilder.Transformer() {
                @Override
                public DynamicType.Builder<?> transform(DynamicType.Builder<?> builder, TypeDescription typeDescription,
                                                        ClassLoader classLoader, JavaModule module, ProtectionDomain protectionDomain) {
                    try {
                        return builder
                                .visit(MemberSubstitution.strict()
                                        .method(named("baseSchemaRegistryConfigDef"))
                                        .replaceWith(MainX2.class.getMethod("baseSchemaRegistryConfigDef"))
                                        .on(any()));
                    } catch (NoSuchMethodException e) {
                        throw new RuntimeException(e);
                    }

                }
            }).installOn(instrumentation);

    SchemaRegistryConfig teSchemaRegistryConfig = new SchemaRegistryConfig(new Properties());

    System.out.println(teSchemaRegistryConfig.baseSchemaRegistryConfigDef().configKeys().size());

}

public static ConfigDef baseSchemaRegistryConfigDef() {
    return new ConfigDef();
}

` I would like to know if it is possible to replace the body of that method with a modified one. I have tried some examples but no success.

[raphw]

It is, but the static initializer will not be rerun on a retransformation. In this case, you would need to hook before the class is loaded for the first time.

[jwalor]

I agree Rafael, with AgentBuilder could I achieve it? If you have any reference it would help me a lot for what I am looking for

[raphw]

You mean rerun the static initializer? That is not possible, unfortunately, the JVM does not support it.

[jwalor]

If I understood what you indicated... ("you would need to hook before the class is loaded for the first time.") could you give me some reference on how I could resolve this case? thank you so much :)

[jwalor]

@raphw
Could you just tell me which api to use?

[raphw]

You are doing it right, but there's nothing that can fix your problem if the initializer already ran.

[jwalor]

Thank you very much for the support! , I found everything about bytebuddy interesting.