[
https://issues.apache.org/jira/browse/FLUME-2870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Denes Arvay reassigned FLUME-2870:
----------------------------------
Assignee: Denes Arvay
> 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
> Assignee: Denes Arvay
> Labels: kafka-source
> Original Estimate: 12h
> Remaining Estimate: 12h
>
> 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)
