diff --git a/component/src/main/java/io/siddhi/extension/map/avro/sinkmapper/AvroSinkMapper.java b/component/src/main/java/io/siddhi/extension/map/avro/sinkmapper/AvroSinkMapper.java index 9e6af1a7..73c2d936 100644 --- a/component/src/main/java/io/siddhi/extension/map/avro/sinkmapper/AvroSinkMapper.java +++ b/component/src/main/java/io/siddhi/extension/map/avro/sinkmapper/AvroSinkMapper.java @@ -81,7 +81,7 @@ syntax = "@sink(type='inMemory', topic='stock', @map(type='avro'," + "schema.def = \"\"\"{\"type\":\"record\",\"name\":\"stock\"," + "\"namespace\":\"stock.example\",\"fields\":[{\"name\":\"symbol\"," + - "\"type\":\"string\"},{\"name\":\"price\":\"type\":\"float\"}," + + "\"type\":\"string\"},{\"name\":\"price\",\"type\":\"float\"}," + "{\"name\":\"volume\",\"type\":\"long\"}]}\"\"\"))\n" + "define stream StockStream (symbol string, price float, volume long);", description = "The above configuration performs a default Avro mapping that generates " +