feat: update JSON schema format for TestRecord in mod.rs (#373)

Author: crossoverJie

.github/workflows/rust.yml

@@ -39,7 +39,7 @@ jobs:
     strategy:
       fail-fast: false
       matrix:
-        pulsar-version: [2.10.6, 2.11.4, 3.0.8, 3.2.4, 3.3.3, 4.0.1]
+        pulsar-version: [2.10.6, 2.11.4, 3.0.8, 3.2.4, 3.3.3, 4.0.1, 4.1.2]
     steps:
       - uses: actions/checkout@v4
       - uses: dtolnay/rust-toolchain@stable

src/consumer/mod.rs

@@ -1231,19 +1231,19 @@ mod tests {
         let client: Pulsar<_> = Pulsar::builder(addr, TokioExecutor).build().await.unwrap();
 
         let json_schema = serde_json::json!({
-            "$id": "https://example.com/test.schema.json",
-            "$schema": "https://json-schema.org/draft/2020-12/schema",
-            "title": "TestRecord",
-            "type": "object",
-            "properties": {
-              "name": {
-                "type": "string",
-              },
-              "age": {
-                "type": "integer",
-                "minimum": 0
-              }
+          "type": "record",
+          "name": "TestRecord",
+          "namespace": "com.example",
+          "fields": [
+            {
+              "name": "name",
+              "type": "string"
+            },
+            {
+              "name": "age",
+              "type": "int"
             }
+          ]
         });
 
         let schema_data = serde_json::to_vec(&json_schema).unwrap();