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

QueryWatermarkOffsets queries one partition at the time #6

Closed vchekan closed 4 years ago

vchekan commented 6 years ago

Description

QueryWatermarkOffsets queries one partition at the time, which is slow and unreasonable because kafka protocol allows querying multiple topics and all partitions.

Expose override which query all partitions and maybe list of topics.

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.