Release 2.12.0

Author: bartelink

CHANGELOG.md

@@ -9,17 +9,21 @@ The `Unreleased` section name is replaced by the expected version of next releas
 ## [Unreleased]
 
 ### Added
+### Changed
+### Removed
+### Fixed
 
-- `Kafka.Producers`: optional constructor parameters [#135](https://github.com/jet/propulsion/pull/135) :pray: [avsaditya19](https://github.com/avsaditya19)
+<a name="2.12.0"></a>
+## [2.12.0] - 2022-01-28
+
+### Added
 
+- `Kafka.Producers`: optional constructor parameters [#135](https://github.com/jet/propulsion/pull/135) :pray: [avsaditya19](https://github.com/avsaditya19)
 
 ### Changed
 
 - `EventStore`: Target `Equinox.EventStore` v `3.0.6` [#136](https://github.com/jet/propulsion/pull/136)
 
-### Removed
-### Fixed
-
 <a name="2.12.0-rc.3"></a>
 ## [2.12.0-rc.3] - 2021-12-24
 
@@ -689,7 +693,8 @@ The `Unreleased` section name is replaced by the expected version of next releas
 
 ## squashed prior to initial relevant commit
 
-[Unreleased]: https://github.com/jet/propulsion/compare/2.12.0-rc.3...HEAD
+[Unreleased]: https://github.com/jet/propulsion/compare/2.12.0...HEAD
+[2.12.0]: https://github.com/jet/propulsion/compare/2.12.0-rc.3...2.12.0
 [2.12.0-rc.3]: https://github.com/jet/propulsion/compare/2.12.0-rc.2...2.12.0-rc.3
 [2.12.0-rc.2]: https://github.com/jet/propulsion/compare/2.12.0-rc.1...2.12.0-rc.2
 [2.12.0-rc.1]: https://github.com/jet/propulsion/compare/2.11.0...2.12.0-rc.1

src/Propulsion.Kafka/Producers.fs

@@ -16,7 +16,7 @@ type Producer
         // Deprecated; there's a good chance this will be removed
         ?degreeOfParallelism,
         /// Miscellaneous configuration parameters to be passed to the underlying Confluent.Kafka producer configuration. Same as constructor argument for Confluent.Kafka >=1.2.
-        ?config, 
+        ?config,
         /// Miscellaneous configuration parameters to be passed to the underlying Confluent.Kafka producer configuration.
         ?custom,
         /// Postprocesses the ProducerConfig after the rest of the rules have been applied
@@ -33,24 +33,19 @@ type Producer
     let produceStats = Streams.Internal.ConcurrentLatencyStats(sprintf "producers(%d)" producers.Length)
     let mutable robin = 0
 
-    member __.DumpStats log = produceStats.Dump log
+    member _.DumpStats log = produceStats.Dump log
 
     /// Execute a producer operation, including recording of the latency statistics for the operation
     /// NOTE: the `execute` function is expected to throw in the event of a failure to produce (this is the standard semantic for all Confluent.Kafka ProduceAsync APIs)
-    member __.Produce(execute : KafkaProducer -> Async<'r>) : Async<'r> = async {
+    member _.Produce(execute : KafkaProducer -> Async<'r>) : Async<'r> = async {
         let producer = producers.[System.Threading.Interlocked.Increment(&robin) % producers.Length]
         let sw = System.Diagnostics.Stopwatch.StartNew()
         let! res = execute producer
         produceStats.Record sw.Elapsed
         return res }
 
     /// Throws if producing fails, per normal Confluent.Kafka 1.x semantics
-    member __.Produce(key, value, ?headers) =
+    member x.Produce(key, value, ?headers) =
         match headers with
-        | Some h -> __.Produce(fun producer -> producer.ProduceAsync(key, value, h) |> Async.Ignore)
-        | None -> __.Produce(fun producer -> producer.ProduceAsync(key, value) |> Async.Ignore)
-
-    [<Obsolete("Please migrate code to an appropriate Produce overload")>]
-    /// Throws if producing fails, per normal Confluent.Kafka 1.x semantics
-    member __.ProduceAsync(key, value) =
-        __.Produce(fun x -> x.ProduceAsync(key, value))
+        | Some h -> x.Produce(fun producer -> producer.ProduceAsync(key, value, h) |> Async.Ignore)
+        | None -> x.Produce(fun producer -> producer.ProduceAsync(key, value) |> Async.Ignore)