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

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

---

API Diff between 1.9.2 and 1.5.5

8 Additions 5 Removals

FsKafka

• public class BatchedConsumer : IDisposable
  • public FSharpAsync<Unit> AwaitCompletion()
  • public FSharpAsync<Unit> AwaitShutdown()
  • public FSharpAsync<Unit> AwaitWithStopOnCancellation()
• public class BatchedProducer : IDisposable
  • public FSharpAsync<DeliveryReport<string, string>[]> ProduceBatch(Tuple<string, string>[] keyValueBatch)
  • 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 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 static KafkaProducerConfig Create<b>(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<IDictionary<string, string>> config, FSharpOption<b> custom, FSharpOption<FSharpFunc<ProducerConfig, Unit>> customize) where b : IEnumerable<KeyValuePair<string, string>>
  • 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>>