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

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

---

API Diff between 1.9.2 and 1.6.2

5 Additions 2 Removals

FsKafka

• 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)