This message was deleted.
# general
s
This message was deleted.
j
Can you just set it to CURRENT_TIMESTAMP in the ingestion spec? ref: https://druid.apache.org/docs/latest/querying/sql-scalar.html#date-and-time-functions
b
There's currently no way to store time of ingestion as a timestamp. If one gets added, it'd have to check that replicas=1. For now, you can have replicas for kafka ingestion, and if you do, the ingestion times can be different on different replicas.
v
CURRENT_TIMESTAMP is only a query thing. It is a SQL scaler it has nothing to do with Kafka ingestion
With Kafka you can use the
kafka
data format to ingest the kafka timestamp as a column (it could be
__time
) then you can compare eventTime to the kafka timestamp to know the lag in publishing your events to kafka
there is no way to record the time the event was added to Druid, kafka timestamp is the closest you can get
l
Yeah, I've tried to use CURRENT_TIMESTAMP or even System.currentTimeMillis() as transformations earlier today, but I was not expecting a success. Thanks for the ideas anyway, folks.
j
Hi, Daniel To insert ingest timestamp into an event, you might be able to write your own extensions that implement org.apache.druid.initialization.DruidModule interface. https://druid.apache.org/docs/latest/development/modules.html you can reference extensions has been implemented to implement it. https://druid.apache.org/docs/latest/development/extensions.html
🤔 1