You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Unfortunately, this won't happen for a couple of reasons. First, kafka-websocket uses the high level consumer, which does not allow explicit setting of offsets. Simple consumer allows setting the offset, but at a very high complexity cost since you then have to explicitly manage almost everything. Second, Kafka deals in offsets, with no concept of time. Something external to Kafka would have to track, on the way in, what offsets correspond to what timestamps and store that information somewhere the consumers can find.
Do you have an idea how to set an starting offset for reads, like it is mentioned here: https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+SimpleConsumer+Example
This offset should be a date, provided as a URL query parameter.
The text was updated successfully, but these errors were encountered: