flinkStreamSQL
flinkStreamSQL copied to clipboard
我们在启动kafkasourced 时候,registerPtMetric(fetcher) bug
在kafka11可以找到consumerThread,但是在kafka2.0版本找不到consumerThread