Are you sure KafkaSource does that? Or do you have an Interceptor?
On Tue, Apr 14, 2015 at 9:50 AM, Tao Li <[email protected]> wrote: > Hi all: > > I found that KafkaSource will put "System.currentTimeMillis()" as > "timestamp" field in header. If we use HDFSEventSink, the HDFS log can be > rotate by the timestamp. > > But the web server log usually contains "timestamp" string, and it indicate > the true timestamp, other than "System.currentTimeMillis()". So I think if > have a feature to allow to customarize the "timestamp" field, will be > better.
