Handles parsing of messages coming from different sources (e.g. Kafka)
parse([{String.t(), String.t()}, ...], map()) :: {pid(), pos_integer(), any()} | String.t()