Adding flag for posting counts to Kafka and error mechanism for decoder exceptions