在使用kafka的avro定义schema的时候,出现了这个异常:
原来代码是这么写的:
String schemaStr = "{\"type\":\"record\",\"name\";\"Student\",\"fields\":[{\"name\":\"id\","type\":\"int\"},{\"name\":\"name\",\"type":"String\"},{\"name\":\"age\","type\":\"int\"}]}";根据上面的提示信息说的type中的String有问题,查了一些资料,后纠正为小写的string:
String schemaStr = "{\"type\":\"record\",\"name\";\"Student\",\"fields\":[{\"name\":\"id\","type\":\"int\"},{\"name\":\"name\",\"type":"string\"},{\"name\":\"age\","type\":\"int\"}]}";
版权声明:本文为QYHuiiQ原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。