Home | About | Sematext search-lucene.com search-hadoop.com
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB
 Search Hadoop and all its subprojects:

Switch to Threaded View
Flume >> mail # user >> Unable to add event header key as require by cassandra onfly


Copy link to this message
-
Unable to add event header key as require by cassandra onfly
Hey Friends,

I've use the following to add event header key in flume config file but as
this is static header fix for all event. Can someone help to add event
header "key" onfly according to the flume event.
I also use
Regex Extractor Interceptor

but seems to be not working or i'm not able to do properly.
agent.sources.avrosource.interceptors = addKey

agent.sources.avrosource.interceptors.addKey.type = static
agent.sources.avrosource.interceptors.addKey.key = key
agent.sources.avrosource.interceptors.addKey.value = hello_world
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB