Reinstate missing line

jet · Dec 24, 2021 · 10a610e · 10a610e
1 parent ad92eb6
commit 10a610e
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/propulsion-reactor/Program.fs b/propulsion-reactor/Program.fs
@@ -566,7 +566,8 @@ let build (args : Args.Arguments) =
         let source, context, monitored, leases, processorName, startFromTail, maxItems, lagFrequency = args.SourceParams()
 #endif
 #else // kafkaEventSpans -> wire up consumption from Kafka, with auxiliary `cosmos` store
-        let consumerConfig =
+            let source = args.Source
+            let consumerConfig =
             FsKafka.KafkaConsumerConfig.Create(
                 AppName, source.Broker, [source.Topic], args.ProcessorName, Confluent.Kafka.AutoOffsetReset.Earliest,
                 maxInFlightBytes = source.MaxInFlightBytes, ?statisticsInterval = source.LagFrequency)