diff --git a/producer/proto/config_impl.go b/producer/proto/config_impl.go index b00dfb3f..94acd9a4 100644 --- a/producer/proto/config_impl.go +++ b/producer/proto/config_impl.go @@ -203,7 +203,7 @@ func (m *SFlowMapper) Map(layer string) MapLayerIterator { func (m *SFlowMapper) ParsePacket(flowMessage ProtoProducerMessageIf, data []byte) (err error) { if m == nil { - return nil + return ParsePacket(flowMessage, data, m, DefaultEnvironment) } return ParsePacket(flowMessage, data, m, m.parserEnvironment) }