Will McQueen created FLUME-1376:
-----------------------------------
Summary: StaticInterceptor doc update
Key: FLUME-1376
URL: https://issues.apache.org/jira/browse/FLUME-1376
Project: Flume
Issue Type: Bug
Components: Docs
Affects Versions: v1.3.0
Reporter: Will McQueen
Assignee: Will McQueen
Priority: Minor
Fix For: v1.3.0
JavaDocs for StaticInterceptor need to be updated from this:
* agent.sources.r1.interceptors.i1.type = timestamp
..to this:
* agent.sources.r1.interceptors.i1.type = static
Confirmed successful output by testing with this config file:
agent.channels = c1
agent.sources = r1
agent.sinks = k1
agent.channels.c1.type = MEMORY
agent.sources.r1.channels = c1
agent.sources.r1.type = SEQ
agent.sources.r1.interceptors = i1
agent.sources.r1.interceptors.i1.type = static
agent.sources.r1.interceptors.i1.preserveExisting = false
agent.sources.r1.interceptors.i1.key = datacenter
agent.sources.r1.interceptors.i1.value= NYC_01
agent.sinks.k1.channel = c1
agent.sinks.k1.type = LOGGER
...and some sample output was:
2012-07-17 10:13:17,981 INFO source.SequenceGeneratorSource: Sequence generator
source starting
2012-07-17 10:13:17,997 INFO sink.LoggerSink: Event: {
headers:{datacenter=NYC_01} body: 30
0 }
2012-07-17 10:13:17,998 INFO sink.LoggerSink: Event: {
headers:{datacenter=NYC_01} body: 31
1 }
2012-07-17 10:13:17,998 INFO sink.LoggerSink: Event: {
headers:{datacenter=NYC_01} body: 32
2 }
2012-07-17 10:13:17,999 INFO sink.LoggerSink: Event: {
headers:{datacenter=NYC_01} body: 33
3 }
2012-07-17 10:13:17,999 INFO sink.LoggerSink: Event: {
headers:{datacenter=NYC_01} body: 34
4 }
Unless requested, I'll just attach the patch here rather than uploading to
ReviewBoard, since it's a very minor update.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators:
https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
