diff --git a/producer/proto/producer_nf.go b/producer/proto/producer_nf.go
index d57925c..5a3f699 100644
--- a/producer/proto/producer_nf.go
+++ b/producer/proto/producer_nf.go
@@ -791,6 +791,7 @@ func ProcessMessageNetFlowV9Config(packet *netflow.NFv9Packet, samplingRateSys S
 		}
 		fmsg.SequenceNum = seqnum
 		fmsg.SamplingRate = uint64(samplingRate)
+		fmsg.ObservationDomainId = obsDomainId
 	}
 	return flowMessageSet, nil
 }