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.

Sign up for GitHub

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

Jump to bottom

Add ParallelProducer #36

Merged

bartelink merged 1 commit into v1 from propulsion

Jun 1, 2019

Collaborator

bartelink commented Jun 1, 2019

Caters for cases where one needs:

Range-driven Ingestion (with async progress checkpointing), e.g. from CosmosDb's ChangeFeedProcessor
the ability to produce messages to Kafka based on the inputs

But does not need:

ordering or deduplication as Streams based algorithms provide
Stream-level isolation
Coalescing of events within a stream

bartelink force-pushed the propulsion branch from bacbc51 to d61b723 Compare

June 1, 2019 04:22


          Add ParallelProducer

0b6607b

bartelink force-pushed the propulsion branch from 23a4cb9 to 0b6607b Compare

June 1, 2019 07:20

bartelink merged commit 8528b6d into v1

bartelink deleted the propulsion branch

June 1, 2019 07:25

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet