Confluent adds a 5-byte magic flag in front of the JSON data payload when their schema serializer is used. This causes Atlas Stream Processing to throw an error as if the json is invalid. 

Failed to parse input message with error:Got parse error at ": could not parse JSON document

This Jira is to track that this should be solved, but the solution isn't decided yet.. If we should just auto-remove this, add a flag, or create a source.format = confluentJson