diff --git a/package-lock.json b/package-lock.json
index be16292e..73d75051 100644
--- a/package-lock.json
+++ b/package-lock.json
@@ -546,6 +546,11 @@
             "integrity": "sha512-Z7tMw1ytTXt5jqMcOP+OQteU1VuNK9Y02uuJtKQ1Sv69jXQKKg5cibLwGJow8yzZP+eAc18EmLGPal0bp36rvQ==",
             "dev": true
         },
+        "avsc": {
+            "version": "5.6.3",
+            "resolved": "https://registry.npmjs.org/avsc/-/avsc-5.6.3.tgz",
+            "integrity": "sha512-awjOvjubyo2Ax+Xzvj97ClgAG9z6q6WDVpD0T+WHWrkWg96nMH1mZKjs51dt1L3+pz3CC0bfoGZ22KvqXapXtw=="
+        },
         "azure-devops-node-api": {
             "version": "7.2.0",
             "resolved": "https://registry.npmjs.org/azure-devops-node-api/-/azure-devops-node-api-7.2.0.tgz",
diff --git a/package.json b/package.json
index 0c48be0b..48d8420a 100644
--- a/package.json
+++ b/package.json
@@ -162,14 +162,23 @@
                     ".kafka"
                 ],
                 "aliases": [
-                    "kafka"
+                    "Kafka DSL"
                 ],
                 "configuration": "./language-configuration.json"
             },
             {
                 "id": "kafka-consumer",
                 "aliases": [
-                    "Kafka Consumer"
+                    "Kafka Consumer View"
+                ]
+            },
+            {
+                "id": "jsonc",
+                "filenamePatterns": [
+                    "*.avsc"
+                ],
+                "aliases": [
+                    "Avro Schema Definition"
                 ]
             }
         ],
@@ -199,6 +208,10 @@
             {
                 "fileMatch": "package.json",
                 "url": "./schemas/package.schema.json"
+            },
+            {
+                "fileMatch": "*.avsc",
+                "url": "./schemas/avro-avsc.json"
             }
         ],
         "commands": [
@@ -320,7 +333,7 @@
                 "command": "vscode-kafka.discover.clusterproviders",
                 "title": "Discover Cluster Providers",
                 "category": "Kafka",
-                "icon":"$(extensions)"
+                "icon": "$(extensions)"
             }
         ],
         "menus": {
@@ -451,6 +464,7 @@
         "test": "node ./out/test/runTest.js"
     },
     "dependencies": {
+        "avsc": "^5.6.3",
         "faker": "^5.5.2",
         "fs-extra": "^8.1.0",
         "glob": "^7.1.6",
@@ -476,4 +490,4 @@
         "webpack": "^5.10.0",
         "webpack-cli": "^4.2.0"
     }
-}
+}
\ No newline at end of file
diff --git a/schemas/avro-avsc.json b/schemas/avro-avsc.json
new file mode 100644
index 00000000..3ecd7c8e
--- /dev/null
+++ b/schemas/avro-avsc.json
@@ -0,0 +1,163 @@
+
+{
+    "$schema": "http://json-schema.org/draft-06/schema#",
+    "title": "Avro Schema Definition",
+    "description": "Json-Schema definition for Avro AVSC files.",
+    "definitions": {
+        "avroSchema": {
+            "title": "Avro Schema",
+            "description": "Root Schema",
+            "oneOf": [
+                { "$ref": "#/definitions/types" }
+            ]
+        },
+        "types": {
+            "title": "Avro Types",
+            "description": "Allowed Avro types",
+            "oneOf": [
+                { "$ref": "#/definitions/primitiveType" },
+                { "$ref": "#/definitions/primitiveTypeWithMetadata" },
+                { "$ref": "#/definitions/customTypeReference" },
+                { "$ref": "#/definitions/avroRecord" },
+                { "$ref": "#/definitions/avroEnum" },
+                { "$ref": "#/definitions/avroArray" },
+                { "$ref": "#/definitions/avroMap" },
+                { "$ref": "#/definitions/avroFixed" },
+                { "$ref": "#/definitions/avroUnion" }
+            ]
+        },
+        "primitiveType": {
+            "title": "Primitive Type",
+            "description": "Basic type primitives.",
+            "type":"string",
+            "enum": [
+                "null",
+                "boolean",
+                "int",
+                "long",
+                "float",
+                "double",
+                "bytes",
+                "string"
+            ]
+        },
+        "primitiveTypeWithMetadata": {
+            "title": "Primitive Type With Metadata",
+            "description": "A primitive type with metadata attached.",
+            "type": "object",
+            "properties": {
+                "type": { "$ref": "#/definitions/primitiveType" }
+            },
+            "required": ["type"]
+        },
+        "customTypeReference": {
+            "title": "Custom Type",
+            "description": "Reference to a ComplexType",
+            "not": { "$ref": "#/definitions/primitiveType" },
+            "type": "string",
+            "pattern": "^[A-Za-z_][A-Za-z0-9_]*(\\.[A-Za-z_][A-Za-z0-9_]*)*$"
+        },
+        "avroUnion": {
+            "title": "Union",
+            "description": "A Union of types",
+            "type": "array",
+            "items": { "$ref": "#/definitions/avroSchema" },
+            "minItems": 1
+        },
+        "avroField": {
+            "title": "Field",
+            "description": "A field within a Record",
+            "type": "object",
+            "properties": {
+                "name": { "$ref": "#/definitions/name" },
+                "type": { "$ref": "#/definitions/types" },
+                "doc": { "type": "string" },
+                "default": { },
+                "order": { "enum": ["ascending", "descending", "ignore"] },
+                "aliases": { "type": "array", "items": { "$ref": "#/definitions/name" } }
+            },
+            "required": ["name", "type"]
+        },
+        "avroRecord": {
+            "title": "Record",
+            "description": "A Record",
+            "type": "object",
+            "properties": {
+                "type": {"type":"string", "enum": ["record"]},
+                "name": { "$ref": "#/definitions/name" },
+                "namespace": { "$ref": "#/definitions/namespace" },
+                "doc": { "type": "string" },
+                "aliases": { "type": "array", "items": { "$ref": "#/definitions/name" } },
+                "fields": { "type": "array", "items": { "$ref": "#/definitions/avroField" } }
+            },
+            "required": ["type", "name", "fields"]
+        },
+        "avroEnum": {
+            "title": "Enum",
+            "description": "An enumeration",
+            "type": "object",
+            "properties": {
+                "type": {"type":"string", "enum": ["enum"]},
+                "name": { "$ref": "#/definitions/name" },
+                "namespace": { "$ref": "#/definitions/namespace" },
+                "doc": { "type": "string" },
+                "aliases": { "type": "array", "items": { "$ref": "#/definitions/name" } },
+                "symbols": { "type": "array", "items": { "$ref": "#/definitions/name" } }
+            },
+            "required": ["type", "name", "symbols"]
+        },
+        "avroArray": {
+            "title": "Array",
+            "description": "An array",
+            "type": "object",
+            "properties": {
+                "type": {"type":"string", "enum": ["array"]},
+                "name": { "$ref": "#/definitions/name" },
+                "namespace": { "$ref": "#/definitions/namespace" },
+                "doc": { "type": "string" },
+                "aliases": { "type": "array", "items": { "$ref": "#/definitions/name" } },
+                "items": { "$ref": "#/definitions/types" }
+            },
+            "required": ["type", "items"]
+        },
+        "avroMap": {
+            "title": "Map",
+            "description": "A map of values",
+            "type": "object",
+            "properties": {
+                "type": {"type":"string", "enum": ["map"]},
+                "name": { "$ref": "#/definitions/name" },
+                "namespace": { "$ref": "#/definitions/namespace" },
+                "doc": { "type": "string" },
+                "aliases": { "type": "array", "items": { "$ref": "#/definitions/name" } },
+                "values": { "$ref": "#/definitions/types" }
+            },
+            "required": ["type", "values"]
+        },
+        "avroFixed": {
+            "title": "Fixed",
+            "description": "A fixed sized array of bytes",
+            "type": "object",
+            "properties": {
+                "type": {"type":"string", "enum": ["fixed"]},
+                "name": { "$ref": "#/definitions/name" },
+                "namespace": { "$ref": "#/definitions/namespace" },
+                "doc": { "type": "string" },
+                "aliases": { "type": "array", "items": { "$ref": "#/definitions/name" } },
+                "size": {"type":"number"}
+            },
+            "required": ["type", "name", "size"]
+        },
+        "name": {
+            "type": "string",
+            "pattern": "^[A-Za-z_][A-Za-z0-9_]*$"
+        },
+        "namespace": {
+            "type": "string",
+            "pattern": "^([A-Za-z_][A-Za-z0-9_]*(\\.[A-Za-z_][A-Za-z0-9_]*)*)*$"
+        }
+    },
+    "oneOf": [
+        { "$ref": "#/definitions/avroSchema" }
+    ]
+}
diff --git a/src/client/serialization.ts b/src/client/serialization.ts
index 45a5a544..4e4ed0d6 100644
--- a/src/client/serialization.ts
+++ b/src/client/serialization.ts
@@ -1,3 +1,5 @@
+import * as avro from "avsc";
+
 export type MessageFormat = "none" | "string" | "double" | "float" | "integer" | "long" | "short";
 
 export type SerializationdResult = any | Error;