Target Confluent.Kafka 1.0.0-RC6

jet · Apr 23, 2019 · 4c2c052 · 4c2c052
1 parent 612d3ed
commit 4c2c052
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git 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
@@ -93,7 +93,7 @@ type KafkaProducer private (log: ILogger, producer : IProducer<string, string>,
  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
@@ -22,7 +22,7 @@
  <PackageReference Include="FSharp.Core" Version="4.3.4" Condition=" '$(TargetFramework)' == 'netstandard2.0' " />
 
  <PackageReference Include="Newtonsoft.Json" Version="11.0.2" />
- <PackageReference Include="Confluent.Kafka" Version="[1.0.0-RC4]" />
+ <PackageReference Include="Confluent.Kafka" Version="[1.0.0-RC6]" />
  <PackageReference Include="librdkafka.redist" Version="[1.0.0]" />
  <PackageReference Include="Serilog" Version="2.7.1" />
  </ItemGroup>