issues
search
jet
/
FsKafka
Minimal F# wrappers for Confluent.Kafka+librdkafka.redist 1.x
https://github.com/jet/dotnet-templates
Apache License 2.0
88
stars
17
forks
source link
Add ParallelProducer
#36
Closed
bartelink
closed
5 years ago
bartelink
commented
5 years ago
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
Caters for cases where one needs:
But does not need:
Streamsbased algorithms provide