You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flume.apache.org by "justdebugit (JIRA)" <ji...@apache.org> on 2016/01/28 05:18:39 UTC
[jira] [Created] (FLUME-2870) Flume agent throw NULLPOINTEXCEPTION
when use kakfa-source
justdebugit created FLUME-2870:
----------------------------------
Summary: Flume agent throw NULLPOINTEXCEPTION when use kakfa-source
Key: FLUME-2870
URL: https://issues.apache.org/jira/browse/FLUME-2870
Project: Flume
Issue Type: Bug
Components: Build
Affects Versions: v1.6.0
Environment: kafka source,es sink
Reporter: justdebugit
CONFIG:
a1.sources = s1
a1.channels = c1
a1.sinks = k1
a1.sources.s1.type = org.apache.flume.source.kafka.KafkaSource
a1.sources.s1.channels = c1
a1.sources.s1.zookeeperConnect = 10.xxx.xxx.160:5181,10.2x.xxx.203:5181/xxx/charge
a1.sources.s1.topic = charge.log
a1.sources.s1.groupId = flume
#a1.channels.c1.type = memory
#a1.channels.c1.capacity = 50000
#a1.channels.c1.transactionCapacity = 100
a1.channels.c1.type = file
a1.channels.c1.checkpointDir = /home/xxxx/app/flume/checkpoint
a1.channels.c1.dataDirs = /home/xxxxx/app/flume/data
a1.channels.c1.capacity = 5000000
a1.sinks.k1.type = com.frontier45.flume.sink.elasticsearch2.ElasticSearchSink
a1.sinks.k1.hostNames = 127.0.0.1:9300
a1.sinks.k1.indexName = xxx_charge_log
a1.sinks.k1.indexType = logs
a1.sinks.k1.clusterName = elasticsearch
a1.sinks.k1.batchSize = 500
a1.sinks.k1.ttl = 3d
a1.sinks.k1.serializer = com.frontier45.flume.sink.elasticsearch2.ElasticSearchLogStashEventSerializer
a1.sinks.k1.channel = c1
EXCEPTION:
28 Jan 2016 11:09:03,830 ERROR [PollableSourceRunner-KafkaSource-s1] (org.apache.flume.source.kafka.KafkaSource.process: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:745)
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)