Posts: 34
Registered: ‎01-11-2016

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.