FsKafka 1.9.2

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

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

API Diff between 1.9.2 and 1.4.5

FsKafka