From 4c2c052e7d4506fc977a7b911692f196b514de00 Mon Sep 17 00:00:00 2001 From: Ruben Bartelink Date: Tue, 23 Apr 2019 08:16:10 +0100 Subject: [PATCH] Target Confluent.Kafka 1.0.0-RC6 --- README.md | 2 +- src/Jet.ConfluentKafka.FSharp/ConfluentKafka.fs | 2 +- src/Jet.ConfluentKafka.FSharp/Jet.ConfluentKafka.FSharp.fsproj | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/README.md b/README.md index 3975037..e892dfc 100644 --- a/README.md +++ b/README.md @@ -13,7 +13,7 @@ See [the Equinox QuickStart](https://github.com/jet/equinox#quickstart) for exam The components within this repository are delivered as (presently single) multi-targeted Nuget package targeting `net461` (F# 3.1+) and `netstandard2.0` (F# 4.5+) profiles - [![NuGet](https://img.shields.io/nuget/vpre/Jet.ConfluentKafka.FSharp.svg)](https://www.nuget.org/packages/Jet.ConfluentKafka.FSharp/) `Jet.ConfluentKafka.FSharp`: Wraps `Confluent.Kafka` to provide efficient batched Kafka Producer and Consumer configurations, with basic logging instrumentation. - [Depends](https://www.fuget.org/packages/Jet.ConfluentKafka.FSharp) on `Confluent.Kafka [1.0.0-RC4]`, `librdkafka [1.0.0]` (pinned to ensure we use a tested pairing enterprise wide), `Serilog` (but no specific Serilog sinks, i.e. you configure to emit to `NLog` etc) and `Newtonsoft.Json` (used internally to parse Statistics for logging purposes). + [Depends](https://www.fuget.org/packages/Jet.ConfluentKafka.FSharp) on `Confluent.Kafka [1.0.0-RC6]`, `librdkafka [1.0.0]` (pinned to ensure we use a tested pairing enterprise wide), `Serilog` (but no specific Serilog sinks, i.e. you configure to emit to `NLog` etc) and `Newtonsoft.Json` (used internally to parse Statistics for logging purposes). ## CONTRIBUTING diff --git a/src/Jet.ConfluentKafka.FSharp/ConfluentKafka.fs b/src/Jet.ConfluentKafka.FSharp/ConfluentKafka.fs index f2d8168..79784c7 100644 --- a/src/Jet.ConfluentKafka.FSharp/ConfluentKafka.fs +++ b/src/Jet.ConfluentKafka.FSharp/ConfluentKafka.fs @@ -93,7 +93,7 @@ type KafkaProducer private (log: ILogger, producer : IProducer, results.[i - 1] <- m if i = numMessages then tcs.TrySetResult results |> ignore for key,value in keyValueBatch do - producer.BeginProduce(topic, Message<_,_>(Key=key, Value=value), deliveryHandler = handler) + producer.Produce(topic, Message<_,_>(Key=key, Value=value), deliveryHandler = handler) producer.Flush(ct) log.Debug("Produced {count}",!numCompleted) return! Async.AwaitTaskCorrect tcs.Task } diff --git a/src/Jet.ConfluentKafka.FSharp/Jet.ConfluentKafka.FSharp.fsproj b/src/Jet.ConfluentKafka.FSharp/Jet.ConfluentKafka.FSharp.fsproj index eaacce4..1d4d4cc 100644 --- a/src/Jet.ConfluentKafka.FSharp/Jet.ConfluentKafka.FSharp.fsproj +++ b/src/Jet.ConfluentKafka.FSharp/Jet.ConfluentKafka.FSharp.fsproj @@ -22,7 +22,7 @@ - +