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.4-rc2

24 Additions 7 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 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 sealed class KafkaConsumerConfig : IEquatable<KafkaConsumerConfig>, IStructuralEquatable
  • 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<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 FSharpAsync<Unit> StartAsChild(IConsumer<k, v> target, string group)
  • public IDisposable Start(IConsumer<k, v> target, string group)
• public class KafkaProducer : IDisposable
  • public FSharpAsync<DeliveryResult<string, string>> ProduceAsync<a>(string key, string value, FSharpOption<a> headers) where a : IEnumerable<Tuple<string, byte[]>>
  • public FSharpAsync<DeliveryResult<string, string>> ProduceAsync(string key, string value, IEnumerable<Tuple<string, byte[]>> headers)
  • public FSharpAsync<DeliveryResult<string, string>> ProduceAsync(string key, string value)
• 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<TimeSpan> requestTimeout, 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>>