[20323][流计算][kafka1.0 fetcher]

Author: simenliuxing

kafka/kafka-source/src/main/java/com/dtstack/flink/sql/source/kafka/CustomerJsonDeserialization.java

@@ -217,7 +217,7 @@ public void setFetcher(AbstractFetcher<Row, ?> fetcher) {
 
     protected void registerPtMetric(AbstractFetcher<Row, ?> fetcher) throws Exception {
 
-        Field consumerThreadField = fetcher.getClass().getSuperclass().getDeclaredField("consumerThread");
+        Field consumerThreadField = fetcher.getClass().getDeclaredField("consumerThread");
         consumerThreadField.setAccessible(true);
         KafkaConsumerThread consumerThread = (KafkaConsumerThread) consumerThreadField.get(fetcher);