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
Can we add an option to specify a timestamp which would be used to seek the consumer offset before we start actual consumer? At this moment it is problematic, as there is no hook between confluent consumer builder and actual consume() call. Fetching timestamp based offsets requires additional call before we start consuming, but after we got partition assigned.
Or maybe it is possible today? We can of course start KafkaBus and then manually seek the consumer after it got assignment but then we risk consuming messages we are not interested in.
reacted with thumbs up emoji reacted with thumbs down emoji reacted with laugh emoji reacted with hooray emoji reacted with confused emoji reacted with heart emoji reacted with rocket emoji reacted with eyes emoji
-
Can we add an option to specify a timestamp which would be used to seek the consumer offset before we start actual consumer? At this moment it is problematic, as there is no hook between confluent consumer builder and actual consume() call. Fetching timestamp based offsets requires additional call before we start consuming, but after we got partition assigned.
Or maybe it is possible today? We can of course start KafkaBus and then manually seek the consumer after it got assignment but then we risk consuming messages we are not interested in.
Beta Was this translation helpful? Give feedback.
All reactions