I have a Kafka topic with some non-JSON test messages in it, resulting in errors "Error: DATA_READ ERROR: Failure while reading messages from kafka. Recordreader was at record: 1"
I don't seem to be able to bypass these topic messages with "store.json.reader.skip_invalid_records" or even an OFFSET in the query. Is there a mechanism or setting I can use to query a topic and not fail on malformed messages?
