diff --git a/propulsion-reactor/Program.fs b/propulsion-reactor/Program.fs
index b09db99a2..744f4ae63 100644
--- 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)