IPullable & WithOffsetResetPolicy(AutoOffsetReset.Earliest) #79
Unanswered
MikeKenyonAccuris
asked this question in
Q&A
Replies: 1 comment
-
|
Hello @MikeKenyonAccuris, |
Beta Was this translation helpful? Give feedback.
0 replies
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
-
We are scanning a KSQL table using a pull query and
.WithOffsetResetPolicy(AutoOffsetReset.Earliest).In upgrading to version 6.0 from 5.1, looks like
CreateQueryStream<>()got replaced withCreatePullQuery<>(), but an IPullable doesn't support the.WithOffsetResetPolicy()modifier.How is one supposed to do this post the 6.0 change?
Beta Was this translation helpful? Give feedback.
All reactions