ByteBuddy AgentBuilder设置挂钩到KafkaListenerContainerFactory的问题

Question

我正在尝试将方法Hook设置为KafkaListenerContainerFactory。KafkaListenerContainerFactory((我在定义方法签名时遇到问题，并且总是得到错误：

java.lang.IollegalArgumentException：无[private-static net.bytebuddy.dynamic.DynamicType$Builder CompanyURL.KafkaListenerAnnotationBeanPostProcessorHook.lambda$install$0，公共静态java.lang.Object CompanyURL。KafkaListenerAnnotationBeanPostProcessorHook.createListenerContainer(java.lang.Object，java.util.concurrent.Callable(throws java.lang.Exception，INSTANCE]允许从公共抽象org.springframework.kafka.listener.MessageListenerContainer org.springfframework.cafka.config.KafkaListerContainerFactory.createListenerContaner(org.springfFramework.kafka.config.KafcaListenerEndpoint(进行委托

Answer 1

有问题的方法返回MessageListenerContainer，而不是智能生命周期。

拦截器只能返回一个可分配的类型，这就是为什么不考虑您可能的拦截器。