FsKafka by @jet @eulerfx @eiriktsarpalis @jgardella @michaelliao5 and contributors

<PackageReference Include="FsKafka" Version="1.9.2" />

---

API Diff between 1.9.2 and 1.4.0

50 Additions 6 Removals

FsKafka

• public class BatchedConsumer : IDisposable
  • public FSharpAsync<Unit> AwaitCompletion()
  • public FSharpAsync<Unit> AwaitShutdown()
  • public FSharpAsync<Unit> AwaitWithStopOnCancellation()
• public class BatchedProducer : IDisposable
  • public static BatchedProducer CreateWithConfigOverrides(ILogger log, KafkaProducerConfig config, string topic, FSharpOption<int> maxInFlight, FSharpOption<TimeSpan> linger)
  • public FSharpAsync<DeliveryReport<string, string>[]> ProduceBatch(Tuple<string, string>[] keyValueBatch)
  • public static BatchedProducer Create(ILogger log, KafkaProducerConfig config, string topic)
  • public FSharpAsync<DeliveryReport<string, string>[]> ProduceBatch(Message<string, string>[] messageBatch)
  • public FSharpAsync<DeliveryReport<string, string>[]> ProduceBatch(IEnumerable<Tuple<string, string>> messageBatch)
  • public FSharpAsync<DeliveryReport<string, string>[]> ProduceBatch(IEnumerable<Tuple<string, string, IEnumerable<Tuple<string, byte[]>>>> messageBatch)
• public static class Config
• public abstract class Batching : IEquatable<Batching>, IStructuralEquatable, IComparable<Batching>, IComparable, IStructuralComparable
  • public class BestEffortSerial : Batching
  • public class Custom : Batching
  • public class Linger : Batching
  • public static class Tags
  • public bool IsBestEffortSerial { get; }
  • public bool IsCustom { get; }
  • public bool IsLinger { get; }
  • public int Tag { get; }
  • public static Batching NewBestEffortSerial(TimeSpan _linger)
  • public static Batching NewCustom(TimeSpan _linger, int _maxInFlight)
  • public static Batching NewLinger(TimeSpan _linger)
• public static class Binding
  • public static Message<string, string> message(ConsumeResult<string, string> x)
  • public static long offsetValue(Offset x)
  • public static int partitionValue(Partition x)
• public sealed class KafkaConsumerConfig : IEquatable<KafkaConsumerConfig>, IStructuralEquatable
  • public static KafkaConsumerConfig Create<a>(string clientId, string bootstrapServers, IEnumerable<string> topics, string groupId, FSharpOption<AutoOffsetReset> autoOffsetReset, FSharpOption<int> fetchMaxBytes, FSharpOption<int> messageMaxBytes, FSharpOption<int?> fetchMinBytes, FSharpOption<TimeSpan> statisticsInterval, FSharpOption<TimeSpan> autoCommitInterval, FSharpOption<IDictionary<string, string>> config, FSharpOption<a> custom, FSharpOption<FSharpFunc<ConsumerConfig, Unit>> customize, FSharpOption<long> minInFlightBytes, FSharpOption<long> maxInFlightBytes, FSharpOption<TimeSpan> maxBatchDelay, FSharpOption<int> maxBatchSize) where a : IEnumerable<KeyValuePair<string, string>>
  • public static KafkaConsumerConfig Create<a>(string clientId, string bootstrapServers, IEnumerable<string> topics, string groupId, AutoOffsetReset autoOffsetReset, FSharpOption<int> fetchMaxBytes, FSharpOption<int> messageMaxBytes, FSharpOption<int?> fetchMinBytes, FSharpOption<TimeSpan> statisticsInterval, FSharpOption<TimeSpan> autoCommitInterval, FSharpOption<bool> allowAutoCreateTopics, FSharpOption<IDictionary<string, string>> config, FSharpOption<a> custom, FSharpOption<FSharpFunc<ConsumerConfig, Unit>> customize, FSharpOption<long> minInFlightBytes, FSharpOption<long> maxInFlightBytes, FSharpOption<TimeSpan> maxBatchDelay, FSharpOption<int> maxBatchSize) where a : IEnumerable<KeyValuePair<string, string>>
• public class KafkaMonitor<k, v>
  • public event FSharpHandler<Tuple<string, int, Exception>> OnCheckFailed
  • public event FSharpHandler<Tuple<string, FSharpList<Tuple<int, PartitionResult>>>> OnStatus
  • public KafkaMonitor(ILogger log, FSharpOption<TimeSpan> interval, FSharpOption<int> windowSize, FSharpOption<int> failResetCount)
  • public IDisposable Start(IConsumer<k, v> target, string group)
• public class KafkaProducer : IDisposable
  • public FSharpAsync<DeliveryResult<string, string>> ProduceAsync(Message<string, string> message)
  • public FSharpAsync<DeliveryResult<string, string>> ProduceAsync(string key, string value, IEnumerable<Tuple<string, byte[]>> headers)
• public class KafkaProducerConfig
  • public double Linger { get; }
  • public static KafkaProducerConfig Create<a>(string clientId, string bootstrapServers, Acks acks, FSharpOption<CompressionType> compression, FSharpOption<int> maxInFlight, FSharpOption<TimeSpan> linger, FSharpOption<int> retries, FSharpOption<TimeSpan> retryBackoff, FSharpOption<TimeSpan> statisticsInterval, FSharpOption<bool> socketKeepAlive, FSharpOption<Partitioner> partitioner, FSharpOption<IDictionary<string, string>> config, FSharpOption<a> custom, FSharpOption<FSharpFunc<ProducerConfig, Unit>> customize) where a : IEnumerable<KeyValuePair<string, string>>
  • public static KafkaProducerConfig Create<a>(string clientId, string bootstrapServers, Acks acks, Batching batching, FSharpOption<CompressionType> compression, FSharpOption<int> retries, FSharpOption<TimeSpan> retryBackoff, FSharpOption<TimeSpan> statisticsInterval, FSharpOption<TimeSpan> requestTimeout, FSharpOption<bool> socketKeepAlive, FSharpOption<Partitioner> partitioner, FSharpOption<int> messageMaxBytes, FSharpOption<IDictionary<string, string>> config, FSharpOption<a> custom, FSharpOption<FSharpFunc<ProducerConfig, Unit>> customize) where a : IEnumerable<KeyValuePair<string, string>>
• public static class MonitorImpl
  • public static class Logging
  • public sealed class PartitionInfo : IEquatable<PartitionInfo>, IStructuralEquatable, IComparable<PartitionInfo>, IComparable, IStructuralComparable
  • public static class Rules
  • public sealed class Window : IEquatable<Window>, IStructuralEquatable
  • public static FSharpAsync<a> run<k, v, a>(IConsumer<k, v> consumer, TimeSpan interval, int windowSize, int failResetCount, string topic, string group, FSharpFunc<Window, Unit> onQuery, FSharpFunc<int, FSharpFunc<Exception, Unit>> onCheckFailed, FSharpFunc<string, FSharpFunc<string, FSharpFunc<FSharpList<Tuple<int, PartitionResult>>, Unit>>> onStatus)
• public class PartitionResult : IEquatable<PartitionResult>, IStructuralEquatable, IComparable<PartitionResult>, IComparable, IStructuralComparable
  • public class ErrorPartitionStalled : PartitionResult
  • public static class Tags
  • public static PartitionResult Healthy { get; }
  • public static PartitionResult OkReachedZero { get; }
  • public static PartitionResult WarningLagIncreasing { get; }
  • public bool IsErrorPartitionStalled { get; }
  • public bool IsHealthy { get; }
  • public bool IsOkReachedZero { get; }
  • public bool IsWarningLagIncreasing { get; }
  • public int Tag { get; }
  • public static PartitionResult NewErrorPartitionStalled(long _lag)