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

added invalid offset constant #15

Closed michaelliao5 closed 6 years ago

michaelliao5 commented 6 years ago

instead of using -1 like kafunk, it uses RD_KAFKA_OFFSET_INVALID constant to align with librdkafka