streaming/validation/drop and reconnect if stream event has malformed JSON
streaming/validation/drop and reconnect if stream event has well-formed JSON not matching schema