THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block |
---|
########################################################################
################## SINK CONFIGURATION ##################################
########################################################################
# The name of the flume agent here is datastream
# The name of the sink here is solr1
# Declaring the Channels
datastream.channels = c1
# Declaring the Sinks
datastream.sinks = solr1
# FQCN (Fully-qualified class name) component type for the type
datastream.sinks.solr1.type = org.apache.flume.sink.solr.SolrSink
# Channel for this sink
datastream.sinks.solr1.channel = c1
datastream.sinks.solr1.serverUrl = http://localhost:8983/solr/flume
# Number of events to be written per transaction
datastream.sinks.solr1.batchSize = 500
# The number of background worker threads used by ConcurrentUpdateSolrServer to empty the queue
datastream.sinks.solr1.threadCount = 2
# Serializes the headers and body of an event into SolrInputDocuments that are sent to Apache Solr
datastream.sinks.solr1.serializer = org.apache.flume.sink.solr.SolrBasicEventSerializer
# A comma-delimited list of headers allowed.
# These must also be valid field names in the schema for this index
datastream.sinks.solr1.serializer.validHeaderFields = loglevel,timestamp,hostname
# The name of the field in the schema used for the event body. 'body' by default.
datastream.sinks.solr1.serializer.bodyFieldname = body
|
...