February 2019
Beginner to intermediate
544 pages
14h 36m
English
Adding creation timestamp for records is the most common practice we have been using for data warehouse applications. The creation timestamp helps us trace different metrics in the future. In most of cases with Flume, event does not have timestamp attached to it by default from source. The timestamp interceptor provides us with the ability to add timestamps for events into the header with timestamp as key. Remember if timestamp is already in the header, interceptor will override the value until and unless the preserveExisting property is set to true, for example:
agent.sources.testsource.interceptors = testInterceptoragent.sources.testsource.interceptors.testInterceptor.type = timestamp
Read now
Unlock full access