Skip to content
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

streaming: add stream partition ingestion processors #57398

Closed
pbardea opened this issue Dec 2, 2020 · 1 comment · Fixed by #58513
Closed

streaming: add stream partition ingestion processors #57398

pbardea opened this issue Dec 2, 2020 · 1 comment · Fixed by #58513
Assignees
Labels
A-disaster-recovery C-enhancement Solution expected to add code/behavior + preserve backward-compat (pg compat issues are exception) T-disaster-recovery

Comments

@pbardea
Copy link
Contributor

pbardea commented Dec 2, 2020

Cluster-to-cluster streams will be ingested via stream partition processors. It will have access to a streaming client which will provide the events for the stream, as well as the address(es) of the partitions to ingest.

The initial version of the processor should just buffer and ingest incoming KVs.

@blathers-crl
Copy link

blathers-crl bot commented Dec 2, 2020

Hi @pbardea, please add a C-ategory label to your issue. Check out the label system docs.

While you're here, please consider adding an A- label to help keep our repository tidy.

🦉 Hoot! I am a Blathers, a bot for CockroachDB. My owner is otan.

@pbardea pbardea added A-disaster-recovery C-enhancement Solution expected to add code/behavior + preserve backward-compat (pg compat issues are exception) labels Dec 2, 2020
@kenliu kenliu added C-enhancement Solution expected to add code/behavior + preserve backward-compat (pg compat issues are exception) and removed C-enhancement Solution expected to add code/behavior + preserve backward-compat (pg compat issues are exception) labels Dec 3, 2020
@pbardea pbardea self-assigned this Dec 21, 2020
@craig craig bot closed this as completed in 418c672 Jan 8, 2021
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
A-disaster-recovery C-enhancement Solution expected to add code/behavior + preserve backward-compat (pg compat issues are exception) T-disaster-recovery
Projects
None yet
Development

Successfully merging a pull request may close this issue.

2 participants