HI, I am using Avro 1.8.1 and trying to parse the following schema_2. Can you please help? val schema: Schema = new Schema.Parser().parse(StrSchema)
I am getting Exception in thread "main" org.apache.avro.SchemaParseException: Illegal initial character: {"type":"record","name":"WS_MESSAGES","fields":[{"name":"message_id","type":"string"},{"name":"action","type":"string"},{"name":"status","type":"string"},{"name":"request","type":"string"},{"name":"response","type":"string"}]} at org.apache.avro.Schema.validateName(Schema.java:1079) at org.apache.avro.Schema.access$200(Schema.java:79) at org.apache.avro.Schema$Name.<init>(Schema.java:436) at org.apache.avro.Schema$Names.get(Schema.java:1043) at org.apache.avro.Schema.parse(Schema.java:1160) at org.apache.avro.Schema$Parser.parse(Schema.java:965) at org.apache.avro.Schema$Parser.parse(Schema.java:953) at main.scala.SampleStreaming$.main(SampleStreaming.scala:42) at main.scala.SampleStreaming.main(SampleStreaming.scala) Schema_2 : "{\"type\":\"record\",\"name\":\"WS_MESSAGES\",\"fields\":[{\"name\":\"message_id\",\"type\":\"string\"},{\"name\":\"action\",\"type\":\"string\"},{\"name\":\"status\",\"type\":\"string\"},{\"name\":\"request\",\"type\":\"string\"},{\"name\":\"response\",\"type\":\"string\"}]}" I initially was trying to parse the following schema_1 but got different error , then manipulated the string to make the schema_2 above. Exception in thread "main" org.apache.avro.SchemaParseException: No type: {"schema":"{\"type\":\"record\",\"name\":\"WS_MESSAGES\",\"fields\":[{\"name\":\"message_id\",\"type\":\"string\"},{\"name\":\"action\",\"type\":\"string\"},{\"name\":\"status\",\"type\":\"string\"},{\"name\":\"request\",\"type\":\"string\"},{\"name\":\"response\",\"type\":\"string\"}],\"connect.name\":\"WS_MESSAGES\"}"} at org.apache.avro.Schema.getRequiredText(Schema.java:1305) at org.apache.avro.Schema.parse(Schema.java:1166) Schema_1: {"schema":"{\"type\":\"record\",\"name\":\"WS_MESSAGES\",\"fields\":[{\"name\":\"message_id\",\"type\":\"string\"},{\"name\":\"action\",\"type\":\"string\"},{\"name\":\"status\",\"type\":\"string\"},{\"name\":\"request\",\"type\":\"string\"},{\"name\":\"response\",\"type\":\"string\"}],\"connect.name\":\"WS_MESSAGES\"}"} Thanks, Amritendu -- View this message in context: http://apache-avro.679487.n3.nabble.com/org-apache-avro-SchemaParseException-Illegal-initial-character-tp4036786.html Sent from the Avro - Developers mailing list archive at Nabble.com.