Update to Propulsion 2.5.2

jet · May 16, 2020 · bcc9388 · bcc9388
1 parent b6c5616
commit bcc9388
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 7 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -13,12 +13,12 @@ The `Unreleased` section name is replaced by the expected version of next releas
 ### Removed
 ### Fixed
 
-<a name="4.7.0"></a>
-## [4.7.0] - 2020-05-27
+<a name="4.7.1"></a>
+## [4.7.1] - 2020-05-16
 
 ### Changed
 
-- Target `Propulsion` v `2.5.1`, `FsKafka` v `1.4.2`
+- Target `Propulsion` v `2.5.2`, `FsKafka` v `1.5.0-beta.2`
 
 ### Fixed
 
@@ -421,8 +421,8 @@ The `Unreleased` section name is replaced by the expected version of next releas
 
 (For information pertaining to earlier releases, see release notes in https://github.com/jet/dotnet-templates/releases and/or can someone please add it!)
 
-[Unreleased]: https://github.com/jet/dotnet-templates/compare/4.7.0...HEAD
-[4.7.0]: https://github.com/jet/dotnet-templates/compare/4.6.0...4.7.0
+[Unreleased]: https://github.com/jet/dotnet-templates/compare/4.7.1...HEAD
+[4.7.1]: https://github.com/jet/dotnet-templates/compare/4.6.0...4.7.1
 [4.6.0]: https://github.com/jet/dotnet-templates/compare/4.5.0...4.6.0
 [4.5.0]: https://github.com/jet/dotnet-templates/compare/4.4.2...4.5.0
 [4.4.2]: https://github.com/jet/dotnet-templates/compare/4.4.1...4.4.2

diff --git a/propulsion-consumer/Program.fs b/propulsion-consumer/Program.fs
@@ -91,10 +91,12 @@ module Logging =
                         c.WriteTo.Console(theme=theme, outputTemplate="[{Timestamp:HH:mm:ss} {Level:u3}] {Message:lj} {Properties}{NewLine}{Exception}")
             |> fun c -> c.CreateLogger()
 
+let [<Literal>] AppName = "ConsumerTemplate"
+
 let start (args : Args.Arguments) =
     let c =
         FsKafka.KafkaConsumerConfig.Create(
-            "ConsumerTemplate",
+            AppName,
             args.Broker, [args.Topic], args.Group, Confluent.Kafka.AutoOffsetReset.Earliest,
             maxInFlightBytes = args.MaxInFlightBytes, ?statisticsInterval = args.LagFrequency)
     //MultiMessages.BatchesSync.Start(c)

diff --git a/propulsion-reactor/Program.fs b/propulsion-reactor/Program.fs
@@ -628,7 +628,7 @@ let build (args : Args.Arguments) =
 //#endif
         let consumerConfig =
             FsKafka.KafkaConsumerConfig.Create(
-                AppName, source.Broker, [source.Topic], args.ConsumerGroupName,
+                AppName, source.Broker, [source.Topic], args.ConsumerGroupName, Confluent.Kafka.AutoOffsetReset.Earliest,
                 maxInFlightBytes = source.MaxInFlightBytes, ?statisticsInterval = source.LagFrequency)
 #endif // kafkaEventSpans