@Override
        public byte[] doInTransform(Instrumentor instrumentor, ClassLoader classLoader, String className, Class<?> classBeingRedefined, ProtectionDomain protectionDomain, byte[] classfileBuffer) throws InstrumentException {
            final InstrumentClass target = instrumentor.getInstrumentClass(classLoader, className, classfileBuffer);
            target.addField(EndPointFieldAccessor.class);

            // api version 13+
            InstrumentMethod responseData = target.getDeclaredMethod("responseData", "java.util.Map", "short");
            if (responseData == null) {
                //api version ~ 12
                responseData = target.getDeclaredMethod("responseData");
            }

            if (responseData != null) {
                responseData.addInterceptor(FetchResponseInterceptor.class);
            }

            return target.toBytecode();
        }
@author Harris Gwag (gwagdalf)
@author Taejin Koo
agent-module/plugins/kafka/src/main/java/com/navercorp/pinpoint/plugin/kafka/KafkaPlugin.java