#flume
flume采集kafka的时候报错，一直循环报错？
KafkaSource.process(KafkaSource.java:153)] KafkaSource EXCEPTION, {} java.lang.NullPointerException at org.apache.flume.instrumentation.MonitoredCounterGroup.increment(MonitoredCounterGroup.java:261) at org.apache.flume.instrumentation.kafka.KafkaSourceCounter.incrementKafkaEmptyCount(KafkaSourceCounter.java:49) at org.apache.flume.source.kafka.KafkaSource.process(KafkaSource.java:146) at org.apache.flume.source.PollableSourceRunner$PollingRunner.run(PollableSourceRunner.java:139) at java.lang.Thread.run(Thread.java:748) 这里的报错是flume1.6版本的一个bug这个bug在1.7版本得到了修复，如果没有打算升级flume版本的话，可以写给flume1.6的源码重新打jar包
https://issues.apache.org/jira/browse/FLUME-2672 这个官方给出的解决方案
将KafkaSourceCounter该类中的
private static final String[] ATTRIBUTES = {TIMER_KAFKA_COMMIT, TIMER_KAFKA_EVENT_GET};
修改为
private static final String[] ATTRIBUTES = {TIMER_KAFKA_COMMIT, TIMER_KAFKA_EVENT_GET, COUNTER_KAFKA_EMPTY};
----------------------------------------------------------------------------------------------------------------------------------------------------
dingwd... 展开详请
ICP备案
云服务器
对象存储
云点播
即时通信 IM
实时音视频
DNS 解析 DNSPod
内容分发网络 CDN
人脸识别
私有网络腾讯云开发者
