Kafka wraps messages in an envelope that contains the offset and the timestamp. Currently, it's not possible to use these timestamps in druid's parseSpec.
This update requires finding a way to append or wrap values sent to parsers with the timestamp, since it's basically not included in the message byte array.
Kafka wraps messages in an envelope that contains the offset and the timestamp. Currently, it's not possible to use these timestamps in druid's parseSpec.
This update requires finding a way to append or wrap values sent to parsers with the timestamp, since it's basically not included in the message byte array.