Hi Team,
I have upgraded Flume application from version 1.6.0 to 1.8.0 & found
that Static Interceptor is not working. Events sent to Kafka doesn't have
any headers specified in Static Interceptor.
agent.sources.source_MonitorActivity.interceptors = interceptor_1
agent.sources.source_MonitorActivity.interceptors.interceptor_1.type =
static
agent.sources.source_MonitorActivity.interceptors.interceptor_1.key = Name
agent.sources.source_MonitorActivity.interceptors.interceptor_1.value = Test
I am using custom source, Is there anything I am missing?
I have created SO question "https://stackoverflow.com/
questions/49174089/apache-flume-1-8-0-static-interceptor-is-not-working"
