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

Solve blocking producer buffer problem #4

Closed vchekan closed 4 years ago

vchekan commented 6 years ago

Description

Confluent producer will block (or throw exception) when internal message buffer is full. This does not play well with async nature of F#.

Consider possible modifications to librdkafka and C# client to keep F# wrapper thin.

bartelink commented 4 years ago

Closing as this is never going to happen. The FsKafka0 module introduced in 1.4.3 provides an onramp to the single practical/viable/maintained/tested API: FsKafka.