Support Questions
Find answers, ask questions, and share your expertise
Alert: Welcome to the Unified Cloudera Community. Former HCC members be sure to read and learn how to activate your account here.

Unable to rename Flume timestamp interceptor's header

Unable to rename Flume timestamp interceptor's header




I use CDH 5.10 and wanted to chenge Flume timestamp interceptor's header name from default 'timestamp' to my own 'ts1' and despite configuration:

a.sources.r4.interceptors.i1timestamp.type = timestamp
a.sources.r4.interceptors.i1timestamp.header = ts1
a.sources.r4.interceptors.i1timestamp.preserveExisting = true

I get messages with header name 'timestamp' on Kafka, where this agent's Sink is pointed.

How to properly change timestamp header name in Flume interceptor?


Best Regards.

Don't have an account?
Coming from Hortonworks? Activate your account here