Merge "Fixed Kafka consumer behaviour on failed deserialization"