There is the possibility to change default offset of new consumers with
SET 'auto.offset.reset'='earliest';
I would like to know if is it possible to specify offset by timestamp like for regular kafka consumer ?
There is the possibility to change default offset of new consumers with
SET 'auto.offset.reset'='earliest';
I would like to know if is it possible to specify offset by timestamp like for regular kafka consumer ?
This is currently not possible as far as I know.
You could always filter by the timestamp of the message (by default:
ROWTIME
) and apply a filter condition usingWHERE
.