Prioritising logs Using Kafka & Logstash

Check this reply for details: