-
Notifications
You must be signed in to change notification settings - Fork 107
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
initial load for queues #1675
initial load for queues #1675
Conversation
c175ea0
to
4b0ccaf
Compare
Loop: | ||
for { | ||
select { | ||
case qrecord, ok := <-stream.Records: |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
seems like a lot of the code below is shared between pub-sub and Kafka, can we unify it?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Also share quite a bit between cdc/qrep. It'll be a mess of conditions. Would be better as an isolated PR
CommitID: 0, | ||
} | ||
|
||
lfn := ls.Env.RawGetString("onRecord") |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
doesn't cdc have to do something similar as well?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Yes, but code is mixed up with tracking LSN/counts
makes sense, might be worth following up with a PR on cleaning some of this up :) |
6bfc8fe
to
3badb8d
Compare
Turns out waitgroup unnecessary since kgo flush handles wait, so removed. Meanwhile, potential send-after-close found in pubsub, so fix
EventHubs is complicated, so skipped. Can be followup