{"id":5386,"date":"2025-04-28T10:00:55","date_gmt":"2025-04-28T06:30:55","guid":{"rendered":"https:\/\/parmin.cloud\/blog\/?p=5386"},"modified":"2025-04-22T10:27:23","modified_gmt":"2025-04-22T06:57:23","slug":"%d8%b3%d8%a7%d8%af%d9%87%d8%b3%d8%a7%d8%b2%db%8c-%d8%af%d8%a7%d8%af%d9%87%d9%87%d8%a7-%d9%88-%d9%86%d8%b3%d8%ae%d9%87%d8%a8%d9%86%d8%af%db%8c-%d8%a8%d8%a7-confluent-schema-r","status":"publish","type":"post","link":"https:\/\/parmin.cloud\/blog\/%d8%b3%d8%a7%d8%af%d9%87%d8%b3%d8%a7%d8%b2%db%8c-%d8%af%d8%a7%d8%af%d9%87%d9%87%d8%a7-%d9%88-%d9%86%d8%b3%d8%ae%d9%87%d8%a8%d9%86%d8%af%db%8c-%d8%a8%d8%a7-confluent-schema-r\/","title":{"rendered":"\u0633\u0627\u062f\u0647\u200c\u0633\u0627\u0632\u06cc \u062f\u0627\u062f\u0647\u200c\u0647\u0627 \u0648 \u0646\u0633\u062e\u0647\u200c\u0628\u0646\u062f\u06cc \u0628\u0627 Confluent Schema Registry \u062f\u0631 Kafka"},"content":{"rendered":"
\u0645\u0642\u062f\u0645\u0647<\/span><\/div>\n
\u0628\u0627 \u0631\u0634\u062f \u06a9\u0633\u0628\u200c\u0648\u06a9\u0627\u0631\u0647\u0627\u060c \u062d\u0641\u0638 \u0633\u0627\u0632\u06af\u0627\u0631\u06cc \u0628\u06cc\u0646 \u0641\u0631\u0645\u062a\u200c\u0647\u0627\u06cc \u062f\u0627\u062f\u0647\u200c\u0627\u06cc \u062f\u0631 \u0647\u0646\u06af\u0627\u0645 \u0627\u0633\u062a\u0631\u06cc\u0645 \u0631\u0648\u06cc\u062f\u0627\u062f\u0647\u0627 \u0627\u0647\u0645\u06cc\u062a \u0632\u06cc\u0627\u062f\u06cc \u062f\u0627\u0631\u062f. \u062f\u0627\u062f\u0647\u200c\u0647\u0627\u06cc \u0630\u062e\u06cc\u0631\u0647\u200c\u0634\u062f\u0647 \u062f\u0631 \u0645\u0648\u0636\u0648\u0639\u0627\u062a Apache Kafka \u062a\u063a\u06cc\u06cc\u0631\u0646\u0627\u067e\u0630\u06cc\u0631 \u0647\u0633\u062a\u0646\u062f \u0648 \u0646\u0645\u06cc\u200c\u062a\u0648\u0627\u0646 \u0622\u0646\u0647\u0627 \u0631\u0627 \u0628\u0647\u200c\u0637\u0648\u0631 \u0628\u0627\u0632\u06af\u0634\u062a\u06cc \u0628\u0631\u0627\u06cc \u062a\u0637\u0628\u06cc\u0642 \u0628\u0627 \u0646\u06cc\u0627\u0632\u0647\u0627\u06cc \u0641\u0639\u0644\u06cc \u062a\u063a\u06cc\u06cc\u0631 \u062f\u0627\u062f. \u0645\u0642\u0627\u0628\u0644\u0647 \u0628\u0627 \u0627\u06cc\u0646 \u0645\u0634\u06a9\u0644 \u0632\u0645\u0627\u0646\u06cc \u06a9\u0647 \u062a\u063a\u06cc\u06cc\u0631\u0627\u062a \u0632\u06cc\u0627\u062f\u06cc \u062f\u0631 \u0627\u0633\u06a9\u06cc\u0645\u0627 \u0648\u062c\u0648\u062f \u062f\u0627\u0634\u062a\u0647 \u0628\u0627\u0634\u062f\u060c \u0645\u06cc\u200c\u062a\u0648\u0627\u0646\u062f \u0686\u0627\u0644\u0634\u200c\u0628\u0631\u0627\u0646\u06af\u06cc\u0632 \u0628\u0627\u0634\u062f.<\/span><\/div>\n
<\/div>\n
Apache Avro \u06cc\u06a9 \u06a9\u062a\u0627\u0628\u062e\u0627\u0646\u0647 \u0633\u0631\u06cc\u0627\u0644\u200c\u0633\u0627\u0632\u06cc \u062f\u0627\u062f\u0647 \u0627\u0633\u062a \u06a9\u0647 \u0628\u0631\u0627\u06cc \u067e\u0627\u06cc\u067e\u200c\u0644\u0627\u06cc\u0646\u200c\u0647\u0627\u06cc \u0627\u0633\u062a\u0631\u06cc\u0645 \u0631\u0648\u06cc\u062f\u0627\u062f \u0637\u0631\u0627\u062d\u06cc \u0634\u062f\u0647 \u0627\u0633\u062a. \u0627\u06cc\u0646 \u06a9\u062a\u0627\u0628\u062e\u0627\u0646\u0647 \u0628\u0647 \u0634\u0645\u0627 \u0627\u062c\u0627\u0632\u0647 \u0645\u06cc\u200c\u062f\u0647\u062f \u0633\u0627\u062e\u062a\u0627\u0631\u0647\u0627\u06cc \u067e\u06cc\u0686\u06cc\u062f\u0647<\/span> (\u06a9\u0647<\/span> \u0628\u0647 \u0622\u0646\u0647\u0627 \u0627\u0633\u06a9\u06cc\u0645\u0627 \u06af\u0641\u062a\u0647 \u0645\u06cc\u200c\u0634\u0648\u062f) \u0628\u0631\u0627\u06cc \u062f\u0627\u062f\u0647\u200c\u0647\u0627\u06cc \u062e\u0648\u062f \u062a\u0639\u0631\u06cc\u0641 \u06a9\u0646\u06cc\u062f \u0648 \u0642\u0627\u0628\u0644\u06cc\u062a\u200c\u0647\u0627\u06cc \u0633\u0631\u06cc\u0627\u0644\u200c\u0633\u0627\u0632\u06cc \u0628\u0631\u0627\u06cc \u062d\u0645\u0644 \u0648 \u0646\u0642\u0644 \u0648 \u0630\u062e\u06cc\u0631\u0647\u200c\u0633\u0627\u0632\u06cc \u06a9\u0627\u0631\u0622\u0645\u062f \u0631\u0627 \u0641\u0631\u0627\u0647\u0645 \u0645\u06cc\u200c\u0622\u0648\u0631\u062f. \u0628\u0631\u0627\u06cc \u067e\u06cc\u06af\u06cc\u0631\u06cc \u0627\u0633\u06a9\u06cc\u0645\u0627\u0647\u0627 \u0648 \u0646\u0633\u062e\u0647\u200c\u0647\u0627\u06cc \u0622\u0646\u200c\u0647\u0627\u060c Confluent Schema Registry \u0627\u06cc\u062c\u0627\u062f \u0634\u062f\u0647 \u0627\u0633\u062a. \u0627\u06cc\u0646 \u0633\u0631\u0648\u06cc\u0633 \u0628\u0647\u200c\u0639\u0646\u0648\u0627\u0646 \u06cc\u06a9 \u0645\u062e\u0632\u0646 \u0645\u062a\u0645\u0631\u06a9\u0632 \u0628\u0631\u0627\u06cc \u0627\u0633\u06a9\u06cc\u0645\u0627\u0647\u0627\u06cc \u0634\u0645\u0627 \u0639\u0645\u0644 \u0645\u06cc\u200c\u06a9\u0646\u062f\u060c \u0630\u062e\u06cc\u0631\u0647\u200c\u0633\u0627\u0632\u06cc \u0622\u0646\u200c\u0647\u0627 \u0631\u0627 \u0645\u062f\u06cc\u0631\u06cc\u062a \u0645\u06cc\u200c\u06a9\u0646\u062f \u0648 \u0633\u0627\u0632\u06af\u0627\u0631\u06cc \u0645\u062a\u0642\u0627\u0628\u0644 \u0631\u0627 \u062a\u0636\u0645\u06cc\u0646 \u0645\u06cc\u200c\u06a9\u0646\u062f. \u0627\u06cc\u0646 \u0627\u0645\u06a9\u0627\u0646 \u0631\u0627 \u0628\u0647 \u0634\u0645\u0627 \u0645\u06cc\u200c\u062f\u0647\u062f \u062a\u0627 \u0628\u0631 \u0631\u0648\u06cc \u062f\u0627\u062f\u0647\u200c\u0647\u0627 \u062a\u0645\u0631\u06a9\u0632 \u06a9\u0646\u06cc\u062f \u0628\u0647 \u062c\u0627\u06cc \u0622\u0646\u06a9\u0647 \u0631\u0648\u0634\u200c\u0647\u0627\u06cc\u06cc \u0628\u0631\u0627\u06cc \u062a\u0628\u062f\u06cc\u0644 \u062f\u0633\u062a\u06cc \u0646\u0633\u062e\u0647\u200c\u0647\u0627\u06cc \u0645\u062e\u062a\u0644\u0641 \u0627\u0633\u06a9\u06cc\u0645\u0627 \u0627\u06cc\u062c\u0627\u062f \u06a9\u0646\u06cc\u062f.<\/span><\/div>\n
<\/div>\n
\u062f\u0631 \u0627\u06cc\u0646 \u0622\u0645\u0648\u0632\u0634\u060c \u0634\u0645\u0627 Confluent Schema Registry \u0631\u0627 \u0628\u0627 \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u0627\u0632 Docker \u0645\u0633\u062a\u0642\u0631 \u062e\u0648\u0627\u0647\u06cc\u062f \u06a9\u0631\u062f \u0648 \u062a\u0648\u0644\u06cc\u062f\u06a9\u0646\u0646\u062f\u0647 \u0648 \u0645\u0635\u0631\u0641\u200c\u06a9\u0646\u0646\u062f\u0647 Kafka \u06a9\u0647 \u062f\u0631 \u0622\u0645\u0648\u0632\u0634\u200c\u0647\u0627\u06cc \u0642\u0628\u0644\u06cc \u0627\u06cc\u0646 \u0633\u0631\u06cc \u0627\u06cc\u062c\u0627\u062f \u06a9\u0631\u062f\u0647\u200c\u0627\u06cc\u062f \u0631\u0627 \u06af\u0633\u062a\u0631\u0634 \u062e\u0648\u0627\u0647\u06cc\u062f \u062f\u0627\u062f. \u0634\u0645\u0627 \u0627\u06cc\u0646 \u0628\u062e\u0634\u200c\u0647\u0627 \u0631\u0627 \u062f\u0648\u0628\u0627\u0631\u0647 \u0637\u0631\u0627\u062d\u06cc \u062e\u0648\u0627\u0647\u06cc\u062f \u06a9\u0631\u062f \u062a\u0627 \u0627\u0634\u06cc\u0627\u0626\u06cc \u0631\u0627 \u06a9\u0647 \u0628\u0627 \u0627\u0633\u06a9\u06cc\u0645\u0627\u0647\u0627\u06cc\u06cc \u06a9\u0647 \u062e\u0648\u062f\u062a\u0627\u0646 \u062a\u0639\u0631\u06cc\u0641 \u06a9\u0631\u062f\u0647\u200c\u0627\u06cc\u062f \u0645\u0637\u0627\u0628\u0642\u062a \u062f\u0627\u0631\u0646\u062f\u060c \u0627\u06cc\u062c\u0627\u062f \u0648 \u0645\u0635\u0631\u0641 \u06a9\u0646\u0646\u062f. \u0647\u0645\u0686\u0646\u06cc\u0646 \u0627\u0633\u06a9\u06cc\u0645\u0627 \u0631\u0627 \u062a\u063a\u06cc\u06cc\u0631 \u062e\u0648\u0627\u0647\u06cc\u062f \u062f\u0627\u062f \u0648 \u06cc\u0627\u062f \u062e\u0648\u0627\u0647\u06cc\u062f \u06af\u0631\u0641\u062a \u06a9\u0647 \u0686\u06af\u0648\u0646\u0647 \u0622\u0646 \u0631\u0627 \u062a\u06a9\u0627\u0645\u0644 \u062f\u0647\u06cc\u062f \u0628\u062f\u0648\u0646 \u0627\u06cc\u0646\u06a9\u0647 \u062f\u0627\u062f\u0647\u200c\u0647\u0627\u06cc \u0645\u062a\u0646\u0627\u0633\u0628 \u0628\u0627 \u0646\u0633\u062e\u0647\u200c\u0647\u0627\u06cc \u0642\u0628\u0644\u06cc \u0634\u06a9\u0633\u062a\u0647 \u0634\u0648\u0646\u062f.<\/span><\/div>\n
<\/div>\n
\u0627\u0644\u0632\u0627\u0645\u0627\u062a<\/span><\/div>\n
\u0628\u0631\u0627\u06cc \u062f\u0646\u0628\u0627\u0644 \u06a9\u0631\u062f\u0646 \u0627\u06cc\u0646 \u0622\u0645\u0648\u0632\u0634\u060c \u0634\u0645\u0627 \u0628\u0647 \u0645\u0648\u0627\u0631\u062f \u0632\u06cc\u0631 \u0646\u06cc\u0627\u0632 \u062f\u0627\u0631\u06cc\u062f:<\/span><\/div>\n
\u2022 \u0646\u0635\u0628 Docker \u0628\u0631 \u0631\u0648\u06cc \u062f\u0633\u062a\u06af\u0627\u0647 \u062e\u0648\u062f. \u0628\u0631\u0627\u06cc \u0633\u06cc\u0633\u062a\u0645\u200c\u0639\u0627\u0645\u0644 Ubuntu\u060c \u0628\u0647 \u0622\u0645\u0648\u0632\u0634<\/span> \u201cHow<\/span> To Install and Use Docker on Ubuntu\u201d \u0645\u0631\u0627\u062c\u0639\u0647 \u06a9\u0646\u06cc\u062f. \u0634\u0645\u0627 \u0641\u0642\u0637 \u0646\u06cc\u0627\u0632 \u0628\u0647 \u0627\u0646\u062c\u0627\u0645 \u0645\u0631\u062d\u0644\u0647 \u0627\u0648\u0644 \u0648 \u062f\u0648\u0645 \u0627\u06cc\u0646 \u0622\u0645\u0648\u0632\u0634 \u062f\u0627\u0631\u06cc\u062f.<\/span><\/div>\n
\u2022 \u0646\u0635\u0628 Docker Compose \u0628\u0631 \u0631\u0648\u06cc \u062f\u0633\u062a\u06af\u0627\u0647 \u062e\u0648\u062f. \u0628\u0631\u0627\u06cc \u0633\u06cc\u0633\u062a\u0645\u200c\u0639\u0627\u0645\u0644 Ubuntu\u060c \u0645\u0631\u0627\u062d\u0644 \u0627\u0648\u0644 \u0648 \u062f\u0648\u0645 \u0622\u0645\u0648\u0632\u0634<\/span> \u201cHow<\/span> To Install and Use Docker Compose on Ubuntu\u201d \u0631\u0627 \u062f\u0646\u0628\u0627\u0644 \u06a9\u0646\u06cc\u062f.<\/span><\/div>\n
\u2022 \u06cc\u06a9 \u067e\u0631\u0648\u0698\u0647 Java \u0628\u0627 Kafka producer \u06a9\u0647 \u0637\u0628\u0642 \u0631\u0627\u0647\u0646\u0645\u0627\u06cc<\/span> \u201cHow<\/span> To Set Up a Kafka Producer to Source Data Through CLI\u201d \u0631\u0627\u0647\u200c\u0627\u0646\u062f\u0627\u0632\u06cc \u0634\u062f\u0647 \u0628\u0627\u0634\u062f.<\/span><\/div>\n
\u2022 \u06cc\u06a9 \u067e\u0631\u0648\u0698\u0647 Java \u0628\u0627 Kafka consumer \u06a9\u0647 \u0637\u0628\u0642 \u0631\u0627\u0647\u0646\u0645\u0627\u06cc<\/span> \u201cHow<\/span> To Set Up a Kafka Consumer to Receive Data Through CLI\u201d \u0631\u0627\u0647\u200c\u0627\u0646\u062f\u0627\u0632\u06cc \u0634\u062f\u0647 \u0628\u0627\u0634\u062f.<\/span><\/div>\n
\u2022 \u0646\u0635\u0628 jq \u0628\u0631 \u0631\u0648\u06cc \u062f\u0633\u062a\u06af\u0627\u0647 \u062e\u0648\u062f. \u0628\u0631\u0627\u06cc \u0622\u0634\u0646\u0627\u06cc\u06cc \u0628\u06cc\u0634\u062a\u0631\u060c \u0628\u0647 \u0645\u0642\u0627\u0644\u0647<\/span> \u201cHow<\/span> To Transform JSON Data with jq\u201d \u0645\u0631\u0627\u062c\u0639\u0647 \u06a9\u0646\u06cc\u062f.<\/span><\/div>\n
\u2022 \u062f\u0631\u06a9 \u0645\u0641\u0627\u0647\u06cc\u0645 Kafka\u060c \u0627\u0632 \u062c\u0645\u0644\u0647 \u0645\u0648\u0636\u0648\u0639\u0627\u062a<\/span> (topics)\u060c<\/span> \u062a\u0648\u0644\u06cc\u062f\u06a9\u0646\u0646\u062f\u06af\u0627\u0646<\/span> (producers)<\/span> \u0648 \u0645\u0635\u0631\u0641\u200c\u06a9\u0646\u0646\u062f\u06af\u0627\u0646<\/span> (consumers).<\/span> \u0628\u0631\u0627\u06cc \u0627\u0637\u0644\u0627\u0639\u0627\u062a \u0628\u06cc\u0634\u062a\u0631\u060c \u0628\u0647 \u0622\u0645\u0648\u0632\u0634<\/span> \u201cIntroduction<\/span> to Kafka\u201d \u0645\u0631\u0627\u062c\u0639\u0647 \u06a9\u0646\u06cc\u062f.<\/span><\/div>\n
\u0645\u0631\u062d\u0644\u0647 1 – \u0631\u0627\u0647\u200c\u0627\u0646\u062f\u0627\u0632\u06cc Schema Registry \u0628\u0627 \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u0627\u0632 Docker Compose<\/span><\/div>\n
<\/div>\n
\u062f\u0631 \u0627\u06cc\u0646 \u0628\u062e\u0634\u060c \u0634\u0645\u0627 \u06cc\u0627\u062f \u062e\u0648\u0627\u0647\u06cc\u062f \u06af\u0631\u0641\u062a \u06a9\u0647 \u0686\u06af\u0648\u0646\u0647 Confluent Schema Registry \u0631\u0627 \u0628\u0627 \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u0627\u0632 Docker Compose \u0631\u0627\u0647\u200c\u0627\u0646\u062f\u0627\u0632\u06cc \u06a9\u0646\u06cc\u062f. \u0628\u0631\u062e\u0644\u0627\u0641 Kafka \u06a9\u0647 \u0645\u06cc\u200c\u062a\u0648\u0627\u0646\u062f \u0628\u0647 \u0635\u0648\u0631\u062a \u0645\u0633\u062a\u0642\u0644 \u0648 \u0628\u0627 \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u0627\u0632 KRaft \u0627\u062c\u0631\u0627 \u0634\u0648\u062f\u060c Schema Registry \u0628\u0647 \u06cc\u06a9 \u0646\u0645\u0648\u0646\u0647 ZooKeeper \u0628\u0631\u0627\u06cc \u0639\u0645\u0644\u06a9\u0631\u062f \u0646\u06cc\u0627\u0632 \u062f\u0627\u0631\u062f.<\/span><\/div>\n
<\/div>\n
\u0628\u0647 \u0639\u0646\u0648\u0627\u0646 \u0628\u062e\u0634\u06cc \u0627\u0632 \u067e\u06cc\u0634\u200c\u0646\u06cc\u0627\u0632\u0647\u0627\u060c \u0634\u0645\u0627 Kafka \u0631\u0627 \u0628\u0647 \u0639\u0646\u0648\u0627\u0646 \u06cc\u06a9 \u0633\u0631\u0648\u06cc\u0633 systemd \u0628\u0631 \u0631\u0648\u06cc \u0645\u0627\u0634\u06cc\u0646 \u0645\u062d\u0644\u06cc \u062e\u0648\u062f \u0645\u0633\u062a\u0642\u0631 \u06a9\u0631\u062f\u0647\u200c\u0627\u06cc\u062f. \u062f\u0631 \u0627\u06cc\u0646 \u0645\u0631\u062d\u0644\u0647\u060c \u0634\u0645\u0627 \u06cc\u06a9 \u06af\u0631\u0647 Kafka \u0631\u0627 \u0627\u0632 \u0637\u0631\u06cc\u0642 Docker Compose \u0645\u0633\u062a\u0642\u0631 \u062e\u0648\u0627\u0647\u06cc\u062f \u06a9\u0631\u062f. \u0627\u0628\u062a\u062f\u0627 \u0628\u0627\u06cc\u062f \u0633\u0631\u0648\u06cc\u0633 Kafka \u0631\u0627 \u0628\u0627 \u0627\u062c\u0631\u0627\u06cc \u062f\u0633\u062a\u0648\u0631 \u0632\u06cc\u0631 \u0645\u062a\u0648\u0642\u0641 \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
sudo systemctl stop kafka<\/span><\/div>\n
\u062d\u0627\u0644 \u0628\u0627\u06cc\u062f \u067e\u06cc\u06a9\u0631\u0628\u0646\u062f\u06cc Docker Compose \u0631\u0627 \u062f\u0631 \u06cc\u06a9 \u0641\u0627\u06cc\u0644 \u0628\u0647 \u0646\u0627\u0645 schema-registry-compose.yaml \u062a\u0639\u0631\u06cc\u0641 \u06a9\u0646\u06cc\u062f. \u0628\u0631\u0627\u06cc \u0627\u06cc\u062c\u0627\u062f \u0648 \u0628\u0627\u0632 \u06a9\u0631\u062f\u0646 \u0622\u0646 \u0628\u0631\u0627\u06cc \u0648\u06cc\u0631\u0627\u06cc\u0634\u060c \u062f\u0633\u062a\u0648\u0631 \u0632\u06cc\u0631 \u0631\u0627 \u0627\u062c\u0631\u0627 \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
nano schema-registry-compose.yaml<\/span><\/div>\n
\u0633\u0637\u0631\u0647\u0627\u06cc \u0632\u06cc\u0631 \u0631\u0627 \u0627\u0636\u0627\u0641\u0647 \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
version:<\/span> ‘3’<\/span><\/div>\n
<\/div>\n
services:<\/span><\/div>\n
\u00a0 zookeeper:<\/span><\/div>\n
\u00a0 \u00a0 image: confluentinc\/cp-zookeeper:latest<\/span><\/div>\n
\u00a0 \u00a0 environment:<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 ZOOKEEPER_CLIENT_PORT: 2181<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 ZOOKEEPER_TICK_TIME: 2000<\/span><\/div>\n
<\/div>\n
\u00a0 kafka:<\/span><\/div>\n
\u00a0 \u00a0 image: confluentinc\/cp-kafka:latest<\/span><\/div>\n
\u00a0 \u00a0 depends_on:<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 – zookeeper<\/span><\/div>\n
\u00a0 \u00a0 ports:<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 – 9092:9092<\/span><\/div>\n
\u00a0 \u00a0 environment:<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 KAFKA_BROKER_ID: 1<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 KAFKA_ADVERTISED_LISTENERS: PLAINTEXT:\/\/kafka:29092,PLAINTEXT_HOST:\/\/localhost:9092<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: PLAINTEXT:PLAINTEXT,PLAINTEXT_HOST:PLAINTEXT<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 KAFKA_INTER_BROKER_LISTENER_NAME: PLAINTEXT<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1<\/span><\/div>\n
<\/div>\n
\u00a0 kafka-schema-registry:<\/span><\/div>\n
\u00a0 \u00a0 image: confluentinc\/cp-schema-registry<\/span><\/div>\n
\u00a0 \u00a0 hostname: kafka-schema-registry<\/span><\/div>\n
\u00a0 \u00a0 container_name: kafka-schema-registry<\/span><\/div>\n
\u00a0 \u00a0 depends_on:<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 – zookeeper<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 – kafka<\/span><\/div>\n
\u00a0 \u00a0 ports:<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 –<\/span> “8081:8081”<\/span><\/div>\n
\u00a0 \u00a0 environment:<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 SCHEMA_REGISTRY_HOST_NAME: kafka-schema-registry<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 SCHEMA_REGISTRY_KAFKASTORE_BOOTSTRAP_SERVERS:<\/span> ‘PLAINTEXT:\/\/kafka:29092’<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 SCHEMA_REGISTRY_LISTENERS: <\/span>http:\/\/0.0.0.0:8081<\/a><\/span><\/div>\n
\u062f\u0631 \u0627\u06cc\u0646\u062c\u0627 \u0634\u0645\u0627 \u0633\u0647 \u0633\u0631\u0648\u06cc\u0633 \u062a\u0639\u0631\u06cc\u0641 \u0645\u06cc\u200c\u06a9\u0646\u06cc\u062f: zookeeper\u060c kafka \u0648 kafka-schema-registry. \u062a\u0645\u0627\u0645\u06cc \u0627\u06cc\u0646 \u0633\u0647 \u0633\u0631\u0648\u06cc\u0633 \u0627\u0632 \u062c\u062f\u06cc\u062f\u062a\u0631\u06cc\u0646 \u062a\u0635\u0627\u0648\u06cc\u0631 Docker \u06a9\u0647 \u062a\u0648\u0633\u0637 Confluent \u0627\u0631\u0627\u0626\u0647 \u0634\u062f\u0647\u200c\u0627\u0646\u062f \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u0645\u06cc\u200c\u06a9\u0646\u0646\u062f. \u0633\u0631\u0648\u06cc\u0633 ZooKeeper \u062f\u0631 \u067e\u0648\u0631\u062a 2181 \u0648 Kafka \u062f\u0631 \u067e\u0648\u0631\u062a 9092 \u062f\u0631 \u062f\u0633\u062a\u0631\u0633 \u062e\u0648\u0627\u0647\u062f \u0628\u0648\u062f. \u0628\u0631\u0627\u06cc Kafka\u060c \u062f\u0631 \u0642\u0633\u0645\u062a environment \u0622\u062f\u0631\u0633 ZooKeeper \u0631\u0627 \u067e\u06cc\u06a9\u0631\u0628\u0646\u062f\u06cc \u06a9\u0631\u062f\u0647 \u0648 \u06cc\u06a9 listener \u0627\u0636\u0627\u0641\u06cc \u062f\u0631 \u067e\u0648\u0631\u062a 29092 \u062a\u0639\u0631\u06cc\u0641 \u0645\u06cc\u200c\u06a9\u0646\u06cc\u062f \u06a9\u0647 Schema Registry \u0627\u0632 \u0622\u0646 \u0628\u0631\u0627\u06cc \u0627\u062a\u0635\u0627\u0644 \u0645\u0633\u062a\u0642\u06cc\u0645 \u0628\u0647 Kafka \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u062e\u0648\u0627\u0647\u062f \u06a9\u0631\u062f. \u0634\u0645\u0627 \u0645\u0634\u062e\u0635 \u0645\u06cc\u200c\u06a9\u0646\u06cc\u062f \u06a9\u0647 \u0633\u0631\u0648\u06cc\u0633 Kafka \u0627\u0628\u062a\u062f\u0627 \u0628\u0627\u06cc\u062f \u0645\u0646\u062a\u0638\u0631 \u0628\u0645\u0627\u0646\u062f \u062a\u0627 ZooKeeper \u0634\u0631\u0648\u0639 \u0628\u0647 \u06a9\u0627\u0631 \u06a9\u0646\u062f.<\/span><\/div>\n
<\/div>\n
\u0633\u067e\u0633\u060c \u0633\u0631\u0648\u06cc\u0633 kafka-schema-registry \u0631\u0627 \u062f\u0631 \u067e\u0648\u0631\u062a 8081 \u062f\u0631 \u062f\u0633\u062a\u0631\u0633 \u0642\u0631\u0627\u0631 \u0645\u06cc\u200c\u062f\u0647\u06cc\u062f \u0648 \u0622\u062f\u0631\u0633 \u0627\u062a\u0635\u0627\u0644 \u0628\u0647 \u0633\u0631\u0648\u06cc\u0633 Kafka \u0631\u0627 \u062f\u0631 \u0642\u0633\u0645\u062a environment \u0645\u0634\u062e\u0635 \u0645\u06cc\u200c\u06a9\u0646\u06cc\u062f. \u0647\u0645\u0686\u0646\u06cc\u0646 \u062a\u0639\u06cc\u06cc\u0646 \u0645\u06cc\u200c\u06a9\u0646\u06cc\u062f \u06a9\u0647 Schema Registry \u0641\u0642\u0637 \u0632\u0645\u0627\u0646\u06cc \u0634\u0631\u0648\u0639 \u0628\u0647 \u06a9\u0627\u0631 \u06a9\u0646\u062f \u06a9\u0647 ZooKeeper \u0648 Kafka \u0628\u0647 \u0637\u0648\u0631 \u06a9\u0627\u0645\u0644 \u0631\u0627\u0647\u200c\u0627\u0646\u062f\u0627\u0632\u06cc \u0634\u062f\u0647 \u0628\u0627\u0634\u0646\u062f.<\/span><\/div>\n
<\/div>\n
\u0641\u0627\u06cc\u0644 \u0631\u0627 \u0630\u062e\u06cc\u0631\u0647 \u06a9\u0631\u062f\u0647 \u0648 \u0622\u0646 \u0631\u0627 \u0628\u0628\u0646\u062f\u06cc\u062f\u060c \u0633\u067e\u0633 \u062f\u0633\u062a\u0648\u0631 \u0632\u06cc\u0631 \u0631\u0627 \u0628\u0631\u0627\u06cc \u0631\u0627\u0647\u200c\u0627\u0646\u062f\u0627\u0632\u06cc \u0633\u0631\u0648\u06cc\u0633\u200c\u0647\u0627 \u062f\u0631 \u067e\u0633\u200c\u0632\u0645\u06cc\u0646\u0647 \u0627\u062c\u0631\u0627 \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
docker-compose<\/span> -f<\/span> schema-registry-compose.yaml up<\/span> -d<\/span><\/div>\n
\u062e\u0631\u0648\u062c\u06cc \u062f\u0631 \u0627\u0646\u062a\u0647\u0627\u06cc \u0627\u062c\u0631\u0627\u06cc \u062f\u0633\u062a\u0648\u0631 \u0645\u0634\u0627\u0628\u0647 \u062e\u0637\u0648\u0637 \u0632\u06cc\u0631 \u062e\u0648\u0627\u0647\u062f \u0628\u0648\u062f:<\/span><\/div>\n
Creating root_zookeeper_1 … done<\/span><\/div>\n
Creating root_kafka_1 \u00a0 \u00a0 … done<\/span><\/div>\n
Creating kafka-schema-registry … done<\/span><\/div>\n
\u0634\u0645\u0627 \u0645\u06cc\u200c\u062a\u0648\u0627\u0646\u06cc\u062f \u0628\u0627 \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u0627\u0632 \u062f\u0633\u062a\u0648\u0631 \u0632\u06cc\u0631\u060c \u06a9\u0627\u0646\u062a\u06cc\u0646\u0631\u0647\u0627\u06cc \u062f\u0631 \u062d\u0627\u0644 \u0627\u062c\u0631\u0627 \u0631\u0627 \u0645\u0634\u0627\u0647\u062f\u0647 \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
docker ps<\/span><\/div>\n
\u062e\u0631\u0648\u062c\u06cc \u0645\u0634\u0627\u0628\u0647 \u0628\u0647 \u0627\u06cc\u0646 \u062e\u0648\u0627\u0647\u062f \u0628\u0648\u062f:<\/span><\/div>\n
CONTAINER ID \u00a0 IMAGE \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0COMMAND \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0CREATED \u00a0 \u00a0 \u00a0 \u00a0 \u00a0STATUS \u00a0 \u00a0 \u00a0 \u00a0 \u00a0PORTS \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 NAMES<\/span><\/div>\n
6783568a74c8 \u00a0 confluentinc\/cp-schema-registry \u00a0 <\/span>\u00a0<\/span>“\/etc\/confluent\/dock\u2026”<\/span> \u00a0 19 seconds ago \u00a0 Up 17 seconds \u00a0 0.0.0.0:8081->8081\/tcp, :::8081->8081\/tcp \u00a0 kafka-schema-registry<\/span><\/div>\n
6367df4b55f7 \u00a0 confluentinc\/cp-kafka:latest \u00a0 \u00a0 \u00a0<\/span> “\/etc\/confluent\/dock\u2026”<\/span> \u00a0 19 seconds ago \u00a0 Up 18 seconds \u00a0 0.0.0.0:9092->9092\/tcp, :::9092->9092\/tcp \u00a0 root_kafka_1<\/span><\/div>\n
a5f5b09984e0 \u00a0 confluentinc\/cp-zookeeper:latest \u00a0<\/span> “\/etc\/confluent\/dock\u2026”<\/span> \u00a0 19 seconds ago \u00a0 Up 19 seconds \u00a0 2181\/tcp, 2888\/tcp, 3888\/tcp \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0root_zookeeper_1<\/span><\/div>\n
<\/div>\n
\u062f\u0631 \u0627\u06cc\u0646 \u0645\u0631\u062d\u0644\u0647\u060c \u0634\u0645\u0627 \u06cc\u06a9 \u0646\u0645\u0648\u0646\u0647 \u0627\u0632 Schema Registry \u0631\u0627 \u0647\u0645\u0631\u0627\u0647 \u0628\u0627 ZooKeeper \u0648 Kafka \u0627\u0632 \u0637\u0631\u06cc\u0642 Docker Compose \u0645\u0633\u062a\u0642\u0631 \u06a9\u0631\u062f\u0647\u200c\u0627\u06cc\u062f. \u062d\u0627\u0644\u0627 \u0634\u0645\u0627 \u06cc\u0627\u062f \u062e\u0648\u0627\u0647\u06cc\u062f \u06af\u0631\u0641\u062a \u06a9\u0647 \u0686\u06af\u0648\u0646\u0647 \u062f\u0631 \u067e\u0631\u0648\u0698\u0647 \u062c\u0627\u0648\u0627\u06cc \u062e\u0648\u062f \u0627\u0632 Avro schemas \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u06a9\u0646\u06cc\u062f.<\/span><\/div>\n
\u0645\u0631\u062d\u0644\u0647 2 – \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u0627\u0632 Avro Schemas<\/span><\/div>\n
<\/div>\n
\u062f\u0631 \u0627\u06cc\u0646 \u0628\u062e\u0634\u060c \u0634\u0645\u0627 \u0628\u0647 \u067e\u0631\u0648\u0698\u0647 \u062e\u0648\u062f Avro \u0631\u0627 \u0627\u0636\u0627\u0641\u0647 \u062e\u0648\u0627\u0647\u06cc\u062f \u06a9\u0631\u062f \u0648 \u0648\u0627\u0628\u0633\u062a\u06af\u06cc\u200c\u0647\u0627\u06cc \u0645\u0631\u0628\u0648\u0637\u0647 \u0631\u0627 \u0627\u0636\u0627\u0641\u0647 \u062e\u0648\u0627\u0647\u06cc\u062f \u06a9\u0631\u062f. \u0634\u0645\u0627 \u06cc\u0627\u062f \u062e\u0648\u0627\u0647\u06cc\u062f \u06af\u0631\u0641\u062a \u06a9\u0647 \u0686\u06af\u0648\u0646\u0647 Avro schemas \u0631\u0627 \u062a\u0639\u0631\u06cc\u0641 \u06a9\u0631\u062f\u0647 \u0648 \u06a9\u0644\u0627\u0633\u200c\u0647\u0627\u06cc \u062c\u0627\u0648\u0627 \u0631\u0627 \u0628\u0631\u0627\u06cc \u0627\u0646\u0648\u0627\u0639 \u062a\u0639\u0631\u06cc\u0641\u200c\u0634\u062f\u0647 \u0628\u0647 \u0637\u0648\u0631 \u062e\u0648\u062f\u06a9\u0627\u0631 \u0627\u06cc\u062c\u0627\u062f \u06a9\u0646\u06cc\u062f. \u0633\u067e\u0633\u060c schema \u062e\u0648\u062f \u0631\u0627 \u0628\u0647 Schema Registry \u0627\u0636\u0627\u0641\u0647 \u062e\u0648\u0627\u0647\u06cc\u062f \u06a9\u0631\u062f.<\/span><\/div>\n
<\/div>\n
\u0627\u0636\u0627\u0641\u0647 \u06a9\u0631\u062f\u0646 Avro \u0628\u0647 \u067e\u0631\u0648\u0698\u0647 \u0634\u0645\u0627<\/span><\/div>\n
<\/div>\n
\u0627\u0628\u062a\u062f\u0627 \u0628\u0627\u06cc\u062f \u0648\u0627\u0628\u0633\u062a\u06af\u06cc org.apache.avro \u0631\u0627 \u0627\u0636\u0627\u0641\u0647 \u06a9\u0646\u06cc\u062f. \u0628\u0647 \u0635\u0641\u062d\u0647 \u0645\u062e\u0632\u0646 Maven \u0628\u0631\u0627\u06cc \u06a9\u0644\u0627\u06cc\u0646\u062a \u062c\u0627\u0648\u0627 \u062f\u0631 \u0645\u0631\u0648\u0631\u06af\u0631 \u062e\u0648\u062f \u0628\u0631\u0648\u06cc\u062f \u0648 \u0622\u062e\u0631\u06cc\u0646 \u0646\u0633\u062e\u0647 \u0645\u0648\u062c\u0648\u062f \u0631\u0627 \u0627\u0646\u062a\u062e\u0627\u0628 \u06a9\u0631\u062f\u0647\u060c \u0633\u067e\u0633 \u0642\u0637\u0639\u0647 XML \u0627\u0631\u0627\u0626\u0647 \u0634\u062f\u0647 \u0628\u0631\u0627\u06cc Maven \u0631\u0627 \u06a9\u067e\u06cc \u06a9\u0646\u06cc\u062f. \u062f\u0631 \u0632\u0645\u0627\u0646 \u0646\u06af\u0627\u0631\u0634 \u0627\u06cc\u0646 \u0645\u0642\u0627\u0644\u0647\u060c \u0622\u062e\u0631\u06cc\u0646 \u0646\u0633\u062e\u0647 \u06a9\u062a\u0627\u0628\u062e\u0627\u0646\u0647 \u06a9\u0644\u0627\u06cc\u0646\u062a \u062c\u0627\u0648\u0627 1.11.3 \u0628\u0648\u062f.<\/span><\/div>\n
\u0648\u0627\u0628\u0633\u062a\u06af\u06cc\u200c\u0647\u0627 \u062f\u0631 \u0641\u0627\u06cc\u0644 pom.xml \u06a9\u0647 \u062f\u0631 \u0631\u06cc\u0634\u0647 \u067e\u0631\u0648\u0698\u0647 \u0634\u0645\u0627 \u0642\u0631\u0627\u0631 \u062f\u0627\u0631\u062f \u0627\u0636\u0627\u0641\u0647 \u0645\u06cc\u200c\u0634\u0648\u0646\u062f. \u0622\u0646 \u0631\u0627 \u0628\u0631\u0627\u06cc \u0648\u06cc\u0631\u0627\u06cc\u0634 \u0628\u0627 \u0627\u062c\u0631\u0627\u06cc \u062f\u0633\u062a\u0648\u0631 \u0632\u06cc\u0631 \u0628\u0627\u0632 \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
nano pom.xml<\/span><\/div>\n
\u0628\u062e\u0634 <dependencies> \u0631\u0627 \u067e\u06cc\u062f\u0627 \u06a9\u0631\u062f\u0647 \u0648 \u062a\u0639\u0631\u06cc\u0641 \u0648\u0627\u0628\u0633\u062a\u06af\u06cc \u0631\u0627 \u0627\u0636\u0627\u0641\u0647 \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
…<\/span><\/div>\n
<!– <\/span>https:\/\/mvnrepository.com\/artifact\/org.apache.avro\/avro<\/a><\/span> –><\/span><\/div>\n
<dependency><\/span><\/div>\n
\u00a0 <groupId>org.apache.avro<\/groupId><\/span><\/div>\n
\u00a0 <artifactId>avro<\/artifactId><\/span><\/div>\n
\u00a0 <version>1.11.3<\/version><\/span><\/div>\n
<\/dependency><\/span><\/div>\n
…<\/span><\/div>\n
\u0627\u06cc\u0646 \u06a9\u0627\u0631 Avro \u0631\u0627 \u062f\u0631 \u062f\u0633\u062a\u0631\u0633 \u067e\u0631\u0648\u0698\u0647 \u0634\u0645\u0627 \u0642\u0631\u0627\u0631 \u0645\u06cc\u200c\u062f\u0647\u062f. \u0628\u0627 \u0627\u06cc\u0646 \u062d\u0627\u0644\u060c \u0628\u0631\u0627\u06cc \u0627\u06cc\u0646 \u06a9\u0647 \u0628\u062a\u0648\u0627\u0646\u06cc\u062f \u06a9\u0644\u0627\u0633\u200c\u0647\u0627\u06cc \u062c\u0627\u0648\u0627 \u0631\u0627 \u0627\u0632 Avro schemas \u062a\u0648\u0644\u06cc\u062f \u06a9\u0646\u06cc\u062f\u060c \u0628\u0627\u06cc\u062f \u0627\u0641\u0632\u0648\u0646\u0647 avro-maven-plugin \u0631\u0627 \u0646\u06cc\u0632 \u0627\u0632 \u0645\u062e\u0632\u0646 Maven \u0628\u0647 \u0647\u0645\u0627\u0646 \u0631\u0648\u0634 \u0627\u0636\u0627\u0641\u0647 \u06a9\u0646\u06cc\u062f.<\/span><\/div>\n
<\/div>\n
\u067e\u0633 \u0627\u0632 \u062a\u0639\u0631\u06cc\u0641 \u0648\u0627\u0628\u0633\u062a\u06af\u06cc\u200c\u0647\u0627\u060c \u0628\u0627\u06cc\u062f \u0627\u0637\u0645\u06cc\u0646\u0627\u0646 \u062d\u0627\u0635\u0644 \u06a9\u0646\u06cc\u062f \u06a9\u0647 \u067e\u0644\u0627\u06af\u06cc\u0646 \u0645\u0646\u0627\u0628\u0639 \u0631\u0627 \u062a\u0648\u0644\u06cc\u062f \u0645\u06cc\u200c\u06a9\u0646\u062f. \u0628\u062e\u0634 <build> \u0641\u0627\u06cc\u0644 pom.xml \u0631\u0627 \u067e\u06cc\u062f\u0627 \u06a9\u0631\u062f\u0647 \u0648 \u062e\u0637\u0648\u0637 \u0632\u06cc\u0631 \u0631\u0627 \u0627\u0636\u0627\u0641\u0647 \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
…<\/span><\/div>\n
<plugin><\/span><\/div>\n
\u00a0 <groupId>org.apache.avro<\/groupId><\/span><\/div>\n
\u00a0 <artifactId>avro-maven-plugin<\/artifactId><\/span><\/div>\n
\u00a0 <version>1.11.3<\/version><\/span><\/div>\n
\u00a0 <executions><\/span><\/div>\n
\u00a0 \u00a0 <execution><\/span><\/div>\n
\u00a0 \u00a0 \u00a0 <phase>generate-sources<\/phase><\/span><\/div>\n
\u00a0 \u00a0 \u00a0 <goals><\/span><\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0 <goal>schema<\/goal><\/span><\/div>\n
\u00a0 \u00a0 \u00a0 <\/goals><\/span><\/div>\n
\u00a0 \u00a0 \u00a0 <configuration><\/span><\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0 <sourceDirectory>${project.basedir}\/src\/main\/java\/com\/dokafka\/<\/sourceDirectory><\/span><\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0 <outputDirectory>${project.basedir}\/src\/main\/java\/<\/outputDirectory><\/span><\/div>\n
\u00a0 \u00a0 \u00a0 <\/configuration><\/span><\/div>\n
\u00a0 \u00a0 <\/execution><\/span><\/div>\n
\u00a0 <\/executions><\/span><\/div>\n
<\/plugin><\/span><\/div>\n
…<\/span><\/div>\n
\u062f\u0631 \u0627\u06cc\u0646\u062c\u0627\u060c \u0634\u0645\u0627 \u0627\u0641\u0632\u0648\u0646\u0647 avro-maven-plugin \u0631\u0627 \u0628\u0631\u0627\u06cc \u062a\u0648\u0644\u06cc\u062f \u0645\u0646\u0627\u0628\u0639 \u062c\u0627\u0648\u0627 \u0628\u0631 \u0627\u0633\u0627\u0633 schemas \u06a9\u0647 \u062f\u0631 \/src\/main\/java\/com\/dokafka \u0642\u0631\u0627\u0631 \u062f\u0627\u0631\u0646\u062f \u0648 \u0642\u0631\u0627\u0631 \u062f\u0627\u062f\u0646 \u0622\u0646\u200c\u0647\u0627 \u062f\u0631 \/src\/main\/java \u067e\u06cc\u06a9\u0631\u0628\u0646\u062f\u06cc \u0645\u06cc\u200c\u06a9\u0646\u06cc\u062f. \u062a\u0648\u062c\u0647 \u062f\u0627\u0634\u062a\u0647 \u0628\u0627\u0634\u06cc\u062f \u06a9\u0647 \u0646\u0628\u0627\u06cc\u062f \u0628\u062e\u0634 <plugins> \u0645\u0648\u062c\u0648\u062f \u062f\u0631 \u0632\u06cc\u0631 <pluginManagement> \u0631\u0627 \u062a\u063a\u06cc\u06cc\u0631 \u062f\u0647\u06cc\u062f.<\/span><\/div>\n
<\/div>\n
\u0628\u0639\u062f \u0627\u0632 \u0627\u0646\u062c\u0627\u0645 \u0627\u06cc\u0646 \u0645\u0631\u0627\u062d\u0644\u060c \u0641\u0627\u06cc\u0644 \u0631\u0627 \u0630\u062e\u06cc\u0631\u0647 \u06a9\u0631\u062f\u0647 \u0648 \u0622\u0646 \u0631\u0627 \u0628\u0628\u0646\u062f\u06cc\u062f.<\/span><\/div>\n
<\/div>\n
\u0628\u0631\u0627\u06cc \u0628\u0631\u0631\u0633\u06cc \u0627\u06cc\u0646\u06a9\u0647 \u0647\u0645\u0647\u200c\u0686\u06cc\u0632 \u0628\u0647 \u062f\u0631\u0633\u062a\u06cc \u067e\u06cc\u06a9\u0631\u0628\u0646\u062f\u06cc \u0634\u062f\u0647 \u0627\u0633\u062a\u060c \u067e\u0631\u0648\u0698\u0647 \u0631\u0627 \u0628\u0633\u0627\u0632\u06cc\u062f:<\/span><\/div>\n
mvn package<\/span><\/div>\n
\u062e\u0631\u0648\u062c\u06cc \u062f\u0631 \u0627\u0646\u062a\u0647\u0627\u06cc \u0627\u062c\u0631\u0627 \u0645\u0634\u0627\u0628\u0647 \u0627\u06cc\u0646 \u062e\u0648\u0627\u0647\u062f \u0628\u0648\u062f:<\/span><\/div>\n
[INFO]<\/span> ————————————————————————<\/span><\/div>\n
[INFO] BUILD SUCCESS<\/span><\/div>\n
[INFO]<\/span> ————————————————————————<\/span><\/div>\n
[INFO] Total time: \u00a05.759 s<\/span><\/div>\n
[INFO] Finished at: 2024-04-01T13:38:31Z<\/span><\/div>\n
[INFO]<\/span> ————————————————————————<\/span><\/div>\n
\u062a\u0639\u0631\u06cc\u0641 Avro Schemas<\/span><\/div>\n
<\/div>\n
\u062f\u0631 \u062d\u0627\u0644 \u062d\u0627\u0636\u0631\u060c \u0634\u0645\u0627 \u06cc\u06a9 schema \u0628\u0647 \u0646\u0627\u0645 TempMeasurement \u0627\u06cc\u062c\u0627\u062f \u062e\u0648\u0627\u0647\u06cc\u062f \u06a9\u0631\u062f \u06a9\u0647 \u06cc\u06a9 \u0627\u0646\u062f\u0627\u0632\u0647\u200c\u06af\u06cc\u0631\u06cc \u062f\u0645\u0627 \u062f\u0631 \u06cc\u06a9 \u0646\u0642\u0637\u0647 \u0632\u0645\u0627\u0646\u06cc \u0631\u0627 \u062a\u0648\u0635\u06cc\u0641 \u0645\u06cc\u200c\u06a9\u0646\u062f. \u0634\u0645\u0627 \u0622\u0646 \u0631\u0627 \u062f\u0631 \u06a9\u0646\u0627\u0631 \u06a9\u0644\u0627\u0633\u200c\u0647\u0627\u06cc ProducerDemo \u0648 ConsumerDemo \u06a9\u0647 \u0628\u0647 \u0639\u0646\u0648\u0627\u0646 \u0628\u062e\u0634\u06cc \u0627\u0632 \u067e\u06cc\u0634\u200c\u0646\u06cc\u0627\u0632\u0647\u0627 \u0627\u06cc\u062c\u0627\u062f \u06a9\u0631\u062f\u0647\u200c\u0627\u06cc\u062f\u060c \u0630\u062e\u06cc\u0631\u0647 \u062e\u0648\u0627\u0647\u06cc\u062f \u06a9\u0631\u062f. \u0628\u0631\u0627\u06cc \u0627\u06cc\u062c\u0627\u062f \u0648 \u0648\u06cc\u0631\u0627\u06cc\u0634 \u0622\u0646 \u062f\u0633\u062a\u0648\u0631 \u0632\u06cc\u0631 \u0631\u0627 \u0627\u062c\u0631\u0627 \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
nano src\/main\/java\/com\/dokafka\/TempMeasurement.avsc<\/span><\/div>\n
\u0633\u0637\u0631\u0647\u0627\u06cc \u0632\u06cc\u0631 \u0631\u0627 \u0627\u0636\u0627\u0641\u0647 \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
{<\/span><\/div>\n
\u00a0<\/span> “namespace”:<\/span> “com.dokafka”,<\/span><\/div>\n
\u00a0<\/span> “name”:<\/span> “TempMeasurement”,<\/span><\/div>\n
\u00a0<\/span> “type”:<\/span> “record”,<\/span><\/div>\n
\u00a0<\/span> “fields”:<\/span> [<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 {<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u00a0<\/span> “name”:<\/span> “measuredValue”,<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u00a0<\/span> “type”:<\/span> “double”<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 },<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 {<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u00a0<\/span> “name”:<\/span> “measurerName”,<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u00a0<\/span> “type”:<\/span> “string”<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 }<\/span><\/div>\n
\u00a0 ]<\/span><\/div>\n
}<\/span><\/div>\n
\u0641\u0627\u06cc\u0644\u200c\u0647\u0627\u06cc Avro schema \u0628\u0647 \u0635\u0648\u0631\u062a JSON \u0646\u0648\u0634\u062a\u0647 \u0645\u06cc\u200c\u0634\u0648\u0646\u062f \u0648 \u067e\u0633\u0648\u0646\u062f \u0641\u0627\u06cc\u0644 \u0622\u0646\u200c\u0647\u0627 .avsc \u0627\u0633\u062a. \u0627\u0628\u062a\u062f\u0627 \u0634\u0645\u0627 namespace schema \u0631\u0627 \u0645\u0634\u062e\u0635 \u0645\u06cc\u200c\u06a9\u0646\u06cc\u062f\u060c \u06a9\u0647 \u0647\u0645\u0686\u0646\u06cc\u0646 namespace \u06a9\u0644\u0627\u0633\u200c\u0647\u0627\u06cc \u062c\u0627\u0648\u0627\u06cc \u062a\u0648\u0644\u06cc\u062f \u0634\u062f\u0647 \u062e\u0648\u0627\u0647\u062f \u0628\u0648\u062f. \u0633\u067e\u0633 \u0646\u0627\u0645 \u0622\u0646 \u0631\u0627 \u0628\u0647 TempMeasurement \u062a\u0646\u0638\u06cc\u0645 \u06a9\u0631\u062f\u0647 \u0648 \u0646\u0648\u0639 schema \u0631\u0627 \u0628\u0647 record \u062a\u0639\u06cc\u06cc\u0646 \u0645\u06cc\u200c\u06a9\u0646\u06cc\u062f\u060c \u06a9\u0647 \u0646\u0634\u0627\u0646\u200c\u062f\u0647\u0646\u062f\u0647 \u06cc\u06a9 \u0634\u06cc\u0621 Avro \u0627\u0633\u062a.<\/span><\/div>\n
\u0633\u067e\u0633\u060c \u0634\u0645\u0627 \u0641\u06cc\u0644\u062f\u0647\u0627\u06cc schema \u062e\u0648\u062f \u0631\u0627 \u06a9\u0647 \u0634\u0627\u0645\u0644 measuredValue \u0648 measurerName \u0627\u0632 \u0646\u0648\u0639\u200c\u0647\u0627\u06cc double \u0648 string \u0628\u0647 \u062a\u0631\u062a\u06cc\u0628 \u0647\u0633\u062a\u0646\u062f\u060c \u0645\u0634\u062e\u0635 \u0645\u06cc\u200c\u06a9\u0646\u06cc\u062f. Avro \u0627\u0632 \u0627\u0646\u0648\u0627\u0639 \u062f\u06cc\u06af\u0631\u06cc \u0645\u0627\u0646\u0646\u062f int\u060c long\u060c float\u060c boolean \u0648 bytes \u0646\u06cc\u0632 \u067e\u0634\u062a\u06cc\u0628\u0627\u0646\u06cc \u0645\u06cc\u200c\u06a9\u0646\u062f.<\/span><\/div>\n
<\/div>\n
\u0641\u0627\u06cc\u0644 \u0631\u0627 \u0630\u062e\u06cc\u0631\u0647 \u06a9\u0631\u062f\u0647 \u0648 \u0622\u0646 \u0631\u0627 \u0628\u0628\u0646\u062f\u06cc\u062f\u060c \u0633\u067e\u0633 \u067e\u0631\u0648\u0698\u0647 \u0631\u0627 \u0628\u0633\u0627\u0632\u06cc\u062f:<\/span><\/div>\n
mvn package<\/span><\/div>\n
\u062d\u0627\u0644\u060c \u0641\u0627\u06cc\u0644\u200c\u0647\u0627 \u0631\u0627 \u0632\u06cc\u0631 \u062f\u0627\u06cc\u0631\u06a9\u062a\u0648\u0631\u06cc src\/main\/java\/com\/dokafka \u0644\u06cc\u0633\u062a \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
ls src\/main\/java\/com\/dokafka<\/span><\/div>\n
\u0634\u0645\u0627 \u0645\u0634\u0627\u0647\u062f\u0647 \u062e\u0648\u0627\u0647\u06cc\u062f \u06a9\u0631\u062f \u06a9\u0647 \u06cc\u06a9 \u06a9\u0644\u0627\u0633 TempMeasurement \u0627\u06cc\u062c\u0627\u062f \u0634\u062f\u0647 \u0627\u0633\u062a:<\/span><\/div>\n
ConsumerDemo.java \u00a0ProducerDemo.java \u00a0TempMeasurement.avsc \u00a0TempMeasurement.java<\/span><\/div>\n
\u0627\u06cc\u0646 \u06a9\u0644\u0627\u0633 \u06a9\u062f\u06cc \u0631\u0627 \u0628\u0631\u0627\u06cc \u0627\u06cc\u062c\u0627\u062f\u060c \u0633\u0631\u06cc\u0627\u0644\u200c\u0633\u0627\u0632\u06cc \u0648 \u062f\u0650\u0633\u0631\u06cc\u0627\u0644\u200c\u0633\u0627\u0632\u06cc \u0627\u0634\u06cc\u0627\u0621 TempMeasurement \u062f\u0631 \u062e\u0648\u062f \u062f\u0627\u0631\u062f.<\/span><\/div>\n
\u0630\u062e\u06cc\u0631\u0647 Schema \u062f\u0631 Schema Registry<\/span><\/div>\n
<\/div>\n
\u062d\u0627\u0644\u0627 \u06a9\u0647 \u0634\u0645\u0627 schema \u062e\u0648\u062f \u0631\u0627 \u062a\u0639\u0631\u06cc\u0641 \u06a9\u0631\u062f\u0647\u200c\u0627\u06cc\u062f\u060c \u0645\u06cc\u200c\u062a\u0648\u0627\u0646\u06cc\u062f \u0622\u0646 \u0631\u0627 \u0628\u0647 Schema Registry \u0627\u0636\u0627\u0641\u0647 \u06a9\u0646\u06cc\u062f \u0628\u0627 \u0627\u062c\u0631\u0627\u06cc \u062f\u0633\u062a\u0648\u0631 \u0632\u06cc\u0631:<\/span><\/div>\n
curl<\/span> -X<\/span> POST<\/span> -H<\/span> “Content-Type:<\/span> application\/vnd.schemaregistry.v1+json” \\<\/span><\/div>\n
\u00a0 \u00a0<\/span> -d<\/span> “$(jq<\/span> -R<\/span> -s<\/span> ‘{“schema”:<\/span> .}’ < src\/main\/java\/com\/dokafka\/TempMeasurement.avsc)” \\<\/span><\/div>\n
\u00a0 \u00a0 <\/span>http:\/\/localhost:8081\/subjects\/TempMeasurement\/versions<\/a><\/span><\/div>\n
Schema Registry \u062f\u0631 \u0622\u062f\u0631\u0633 <\/span>http:\/\/localhost:8081<\/a><\/span> \u062f\u0631 \u062f\u0633\u062a\u0631\u0633 \u0627\u0633\u062a \u0648 \u0627\u0632 \u0637\u0631\u06cc\u0642 HTTP \u0642\u0627\u0628\u0644 \u062f\u0633\u062a\u0631\u0633\u06cc \u0627\u0633\u062a. \u062f\u0631 \u0627\u06cc\u0646 \u062f\u0633\u062a\u0648\u0631\u060c \u0627\u0628\u062a\u062f\u0627 \u0645\u062a\u062f HTTP \u0631\u0627 \u0628\u0647 POST \u062a\u0646\u0638\u06cc\u0645 \u0645\u06cc\u200c\u06a9\u0646\u06cc\u062f \u0647\u0645\u0631\u0627\u0647 \u0628\u0627 Content-Type \u0645\u0646\u0627\u0633\u0628 \u06a9\u0647 Registry \u0622\u0646 \u0631\u0627 \u0642\u0628\u0648\u0644 \u0645\u06cc\u200c\u06a9\u0646\u062f.<\/span><\/div>\n
<\/div>\n
\u0634\u0645\u0627 \u0628\u062f\u0646\u0647 \u062f\u0631\u062e\u0648\u0627\u0633\u062a \u0631\u0627 \u0628\u0647<\/span> -d<\/span> \u0645\u06cc\u200c\u062f\u0647\u06cc\u062f \u0648 \u0627\u0632 jq \u0628\u0631\u0627\u06cc \u0628\u0633\u062a\u0647\u200c\u0628\u0646\u062f\u06cc \u0645\u062d\u062a\u0648\u0627\u06cc schema \u062f\u0631 \u06cc\u06a9 \u0641\u06cc\u0644\u062f \u0628\u0647 \u0646\u0627\u0645 schema \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u0645\u06cc\u200c\u06a9\u0646\u06cc\u062f\u060c \u0632\u06cc\u0631\u0627 \u0627\u06cc\u0646 \u0641\u0631\u0645\u062a \u0627\u0633\u062a \u06a9\u0647 Schema Registry \u0622\u0646 \u0631\u0627 \u0645\u06cc\u200c\u067e\u0630\u06cc\u0631\u062f. \u062f\u0631 \u0646\u0647\u0627\u06cc\u062a\u060c \u062f\u0631\u062e\u0648\u0627\u0633\u062a \u0631\u0627 \u0628\u0647 subjects\/TempMeasurement\/versions \u0647\u062f\u0627\u06cc\u062a \u0645\u06cc\u200c\u06a9\u0646\u06cc\u062f\u060c \u062c\u0627\u06cc\u06cc \u06a9\u0647 \u0634\u0645\u0627 \u0645\u0634\u062e\u0635 \u0645\u06cc\u200c\u06a9\u0646\u06cc\u062f \u06a9\u0647 schema \u062c\u062f\u06cc\u062f \u0686\u06af\u0648\u0646\u0647 \u0628\u0627\u06cc\u062f \u0646\u0627\u0645\u200c\u06af\u0630\u0627\u0631\u06cc \u0634\u0648\u062f.<\/span><\/div>\n
<\/div>\n
\u062e\u0631\u0648\u062c\u06cc \u0628\u0647 \u0635\u0648\u0631\u062a \u0632\u06cc\u0631 \u062e\u0648\u0627\u0647\u062f \u0628\u0648\u062f:<\/span><\/div>\n
{“id”:1}<\/span><\/div>\n
Schema Registry \u062f\u0631\u062e\u0648\u0627\u0633\u062a \u0631\u0627 \u067e\u0630\u06cc\u0631\u0641\u062a\u0647 \u0648 \u0628\u0647 \u0622\u0646 ID \u0634\u0645\u0627\u0631\u0647 1 \u0627\u062e\u062a\u0635\u0627\u0635 \u062f\u0627\u062f\u0647 \u0627\u0633\u062a.<\/span><\/div>\n
<\/div>\n
\u0628\u0631\u0627\u06cc \u0645\u0634\u0627\u0647\u062f\u0647 \u062a\u0645\u0627\u0645 schemas \u0645\u0648\u062c\u0648\u062f\u060c \u062f\u0633\u062a\u0648\u0631 \u0632\u06cc\u0631 \u0631\u0627 \u0627\u062c\u0631\u0627 \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
curl<\/span> -X<\/span> GET <\/span>http:\/\/localhost:8081\/subjects<\/a><\/span><\/div>\n
\u0634\u0645\u0627 \u062a\u0646\u0647\u0627 \u06cc\u06a9 schema \u0645\u0648\u062c\u0648\u062f \u062e\u0648\u0627\u0647\u06cc\u062f \u062f\u06cc\u062f:<\/span><\/div>\n
[“TempMeasurement”]<\/span><\/div>\n
\u062f\u0631 \u0627\u06cc\u0646 \u0645\u0631\u062d\u0644\u0647\u060c \u0634\u0645\u0627 \u0648\u0627\u0628\u0633\u062a\u06af\u06cc\u200c\u0647\u0627\u06cc \u0644\u0627\u0632\u0645 \u0631\u0627 \u0628\u0647 \u067e\u0631\u0648\u0698\u0647 Maven \u062e\u0648\u062f \u0627\u0636\u0627\u0641\u0647 \u06a9\u0631\u062f\u0647\u200c\u0627\u06cc\u062f \u0648 \u06a9\u062f \u062e\u0648\u062f\u06a9\u0627\u0631\u0633\u0627\u0632\u06cc \u0628\u0631\u0627\u06cc Avro schemas \u06a9\u0647 \u062a\u0639\u0631\u06cc\u0641 \u0645\u06cc\u200c\u06a9\u0646\u06cc\u062f \u0631\u0627 \u067e\u06cc\u06a9\u0631\u0628\u0646\u062f\u06cc \u06a9\u0631\u062f\u0647\u200c\u0627\u06cc\u062f. \u0627\u06a9\u0646\u0648\u0646 \u0634\u0645\u0627 \u0622\u0645\u0627\u062f\u0647 \u0647\u0633\u062a\u06cc\u062f \u06a9\u0647 \u062f\u0627\u062f\u0647\u200c\u0647\u0627 \u0631\u0627 \u0628\u0631 \u0627\u0633\u0627\u0633 schemas \u062a\u0648\u0644\u06cc\u062f \u0648 \u0645\u0635\u0631\u0641 \u06a9\u0646\u06cc\u062f.<\/span><\/div>\n
\u0645\u0631\u062d\u0644\u0647 3 – \u062a\u0648\u0644\u06cc\u062f \u0648 \u0645\u0635\u0631\u0641 \u062f\u0627\u062f\u0647\u200c\u0647\u0627 \u0637\u0628\u0642 Schemas<\/span><\/div>\n
<\/div>\n
Confluent \u06cc\u06a9 \u06a9\u062a\u0627\u0628\u062e\u0627\u0646\u0647 Avro serializer \u0628\u0631\u0627\u06cc Kafka \u0628\u0647 \u0646\u0627\u0645 kafka-avro-serializer \u0641\u0631\u0627\u0647\u0645 \u06a9\u0631\u062f\u0647 \u0627\u0633\u062a. \u062f\u0631 \u0627\u06cc\u0646 \u0645\u0631\u062d\u0644\u0647\u060c \u0634\u0645\u0627 \u0627\u06cc\u0646 \u06a9\u062a\u0627\u0628\u062e\u0627\u0646\u0647 \u0631\u0627 \u0628\u0647 \u067e\u0631\u0648\u0698\u0647 \u062e\u0648\u062f \u0627\u0636\u0627\u0641\u0647 \u062e\u0648\u0627\u0647\u06cc\u062f \u06a9\u0631\u062f \u0648 producer \u0648 consumer \u062e\u0648\u062f \u0631\u0627 \u0628\u0631\u0627\u06cc \u0627\u0631\u0633\u0627\u0644 \u0648 \u062f\u0631\u06cc\u0627\u0641\u062a \u0627\u0634\u06cc\u0627\u0621 TempMeasurement \u067e\u06cc\u06a9\u0631\u0628\u0646\u062f\u06cc \u0645\u06cc\u200c\u06a9\u0646\u06cc\u062f.<\/span><\/div>\n
<\/div>\n
\u0627\u0641\u0632\u0648\u062f\u0646 \u0648\u0627\u0628\u0633\u062a\u06af\u06cc\u200c\u0647\u0627\u06cc \u0644\u0627\u0632\u0645<\/span><\/div>\n
<\/div>\n
\u0628\u0631\u0627\u06cc \u0627\u0641\u0632\u0648\u062f\u0646 \u0627\u06cc\u0646 \u06a9\u062a\u0627\u0628\u062e\u0627\u0646\u0647 \u0628\u0647 \u067e\u0631\u0648\u0698\u0647 \u062e\u0648\u062f\u060c \u0628\u0647 \u0645\u062e\u0632\u0646 Maven \u0628\u0631\u0648\u06cc\u062f \u0648 \u062a\u0639\u0631\u06cc\u0641 XML \u0628\u0631\u0627\u06cc \u0622\u062e\u0631\u06cc\u0646 \u0646\u0633\u062e\u0647 \u0645\u0648\u062c\u0648\u062f \u0631\u0627 \u06a9\u067e\u06cc \u06a9\u0646\u06cc\u062f<\/span> (\u0646\u0633\u062e\u0647\u200c\u0627\u06cc<\/span> \u06a9\u0647 \u062f\u0631 \u0632\u0645\u0627\u0646 \u0646\u06af\u0627\u0631\u0634 \u0627\u06cc\u0646 \u0645\u0637\u0644\u0628 \u0628\u0647\u200c\u0631\u0648\u0632\u062a\u0631\u06cc\u0646 \u0628\u0648\u062f\u060c \u0646\u0633\u062e\u0647 7.6.0 \u0628\u0648\u062f). \u0633\u067e\u0633\u060c \u0641\u0627\u06cc\u0644 pom.xml \u0631\u0627 \u0628\u0631\u0627\u06cc \u0648\u06cc\u0631\u0627\u06cc\u0634 \u0628\u0627\u0632 \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
nano pom.xml<\/span><\/div>\n
\u0627\u0632 \u0622\u0646\u062c\u0627\u06cc\u06cc \u06a9\u0647 \u0628\u0633\u062a\u0647 kafka-avro-serializer \u062f\u0631 \u0645\u062e\u0632\u0646 Maven Confluent \u0645\u06cc\u0632\u0628\u0627\u0646\u06cc \u0645\u06cc\u200c\u0634\u0648\u062f\u060c \u0628\u0627\u06cc\u062f \u0622\u0646 \u0631\u0627 \u0628\u0627 \u0627\u0641\u0632\u0648\u062f\u0646 \u062e\u0637\u0648\u0637 \u0632\u06cc\u0631 \u062a\u0639\u0631\u06cc\u0641 \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
<repositories><\/span><\/div>\n
\u00a0 <repository><\/span><\/div>\n
\u00a0 \u00a0 <id>confluent<\/id><\/span><\/div>\n
\u00a0 \u00a0 <url><\/span>http:\/\/packages.confluent.io\/maven\/<\/a><\/span><\/url><\/span><\/div>\n
\u00a0 <\/repository><\/span><\/div>\n
<\/repositories><\/span><\/div>\n
\u0633\u067e\u0633\u060c \u062a\u0639\u0631\u06cc\u0641 \u06a9\u062a\u0627\u0628\u062e\u0627\u0646\u0647 \u0631\u0627 \u0628\u0647 \u0628\u062e\u0634 <dependencies> \u0627\u0636\u0627\u0641\u0647 \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
<dependency><\/span><\/div>\n
\u00a0 <groupId>io.confluent<\/groupId><\/span><\/div>\n
\u00a0 <artifactId>kafka-avro-serializer<\/artifactId><\/span><\/div>\n
\u00a0 <version>7.6.0<\/version><\/span><\/div>\n
<\/dependency><\/span><\/div>\n
\u0628\u0631\u0627\u06cc \u0627\u06cc\u0646\u06a9\u0647 \u0645\u0634\u062a\u0631\u06cc Kafka \u0628\u062a\u0648\u0627\u0646\u062f \u0628\u0627 Schema Registry \u0627\u0631\u062a\u0628\u0627\u0637 \u0628\u0631\u0642\u0631\u0627\u0631 \u06a9\u0646\u062f\u060c \u0647\u0645\u0686\u0646\u06cc\u0646 \u0628\u0627\u06cc\u062f kafka-schema-registry-client \u0631\u0627 \u0628\u0647\u200c\u0639\u0646\u0648\u0627\u0646 \u06cc\u06a9 \u0648\u0627\u0628\u0633\u062a\u06af\u06cc \u0627\u0636\u0627\u0641\u0647 \u06a9\u0646\u06cc\u062f.<\/span><\/div>\n
<\/div>\n
\u067e\u0633 \u0627\u0632 \u0627\u0646\u062c\u0627\u0645 \u0627\u06cc\u0646 \u062a\u063a\u06cc\u06cc\u0631\u0627\u062a\u060c \u0641\u0627\u06cc\u0644 \u0631\u0627 \u0630\u062e\u06cc\u0631\u0647 \u06a9\u0631\u062f\u0647 \u0648 \u0628\u0633\u062a\u0647 \u0631\u0627 \u06a9\u0627\u0645\u067e\u0627\u06cc\u0644 \u06a9\u0646\u06cc\u062f.<\/span><\/div>\n
<\/div>\n
\u0628\u0647\u200c\u0631\u0648\u0632\u0631\u0633\u0627\u0646\u06cc \u06a9\u0644\u0627\u0633\u200c\u0647\u0627\u06cc ProducerDemo \u0648 ConsumerDemo<\/span><\/div>\n
<\/div>\n
\u0628\u0647\u200c\u0631\u0648\u0632\u0631\u0633\u0627\u0646\u06cc ProducerDemo<\/span><\/div>\n
<\/div>\n
\u06a9\u0644\u0627\u0633 ProducerDemo \u0631\u0627 \u0628\u0631\u0627\u06cc \u0627\u062a\u0635\u0627\u0644 \u0628\u0647 Schema Registry \u0648 \u062a\u0648\u0644\u06cc\u062f \u0627\u0634\u06cc\u0627\u0621 \u0627\u0632 \u0646\u0648\u0639 TempMeasurement \u062f\u0631 \u06cc\u06a9 topic \u0628\u0647\u200c\u0631\u0648\u0632\u0631\u0633\u0627\u0646\u06cc \u06a9\u0646\u06cc\u062f. \u0627\u0628\u062a\u062f\u0627 \u0622\u0646 \u0631\u0627 \u0628\u0631\u0627\u06cc \u0648\u06cc\u0631\u0627\u06cc\u0634 \u0628\u0627\u0632 \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
nano src\/main\/java\/com\/dokafka\/ProducerDemo.java<\/span><\/div>\n
\u06a9\u062a\u0627\u0628\u062e\u0627\u0646\u0647\u200c\u0647\u0627\u06cc KafkaAvroSerializer \u0648 KafkaAvroSerializerConfig \u0631\u0627 \u0648\u0627\u0631\u062f \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
import org.apache.kafka.common.serialization.StringSerializer;<\/span><\/div>\n
import io.confluent.kafka.serializers.KafkaAvroSerializer;<\/span><\/div>\n
import io.confluent.kafka.serializers.KafkaAvroSerializerConfig;<\/span><\/div>\n
\u0633\u067e\u0633\u060c \u0628\u062e\u0634 \u0627\u0648\u0644 \u0645\u062a\u062f main \u0631\u0627 \u0628\u0647 \u0635\u0648\u0631\u062a \u0632\u06cc\u0631 \u062a\u063a\u06cc\u06cc\u0631 \u062f\u0647\u06cc\u062f:<\/span><\/div>\n
String topicName =<\/span> “java_demo_avro”;<\/span><\/div>\n
<\/div>\n
Properties properties = new Properties();<\/span><\/div>\n
properties.setProperty(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);<\/span><\/div>\n
properties.setProperty(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());<\/span><\/div>\n
properties.setProperty(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, KafkaAvroSerializer.class.getName());<\/span><\/div>\n
properties.setProperty(KafkaAvroSerializerConfig.SCHEMA_REGISTRY_URL_CONFIG,<\/span> “<\/span>http:\/\/localhost:8081<\/a><\/span>“);<\/span><\/div>\n
<\/div>\n
KafkaProducer<String, TempMeasurement> producer = new KafkaProducer<>(properties);<\/span><\/div>\n
<\/div>\n
ProducerRecord<String, TempMeasurement> producerRecord =<\/span><\/div>\n
\u00a0 new ProducerRecord<>(topicName, new TempMeasurement(Double.parseDouble(args[0]), args[1]));<\/span><\/div>\n
\u062f\u0631 \u0627\u06cc\u0646\u062c\u0627:<\/span><\/div>\n
\u2022 \u0646\u0627\u0645 topic \u0631\u0627 \u0628\u0647 java_demo_avro \u062a\u0646\u0638\u06cc\u0645 \u0645\u06cc\u200c\u06a9\u0646\u06cc\u062f. Kafka \u0627\u06cc\u0646 topic \u0631\u0627 \u0627\u06af\u0631 \u0642\u0628\u0644\u0627\u064b \u0648\u062c\u0648\u062f \u0646\u062f\u0627\u0634\u062a\u0647 \u0628\u0627\u0634\u062f\u060c \u0627\u06cc\u062c\u0627\u062f \u062e\u0648\u0627\u0647\u062f \u06a9\u0631\u062f.<\/span><\/div>\n
\u2022 \u06a9\u0644\u0627\u0633 serializer \u0628\u0631\u0627\u06cc \u0645\u0642\u062f\u0627\u0631 \u0631\u0627 \u0627\u0632 StringSerializer \u0628\u0647 KafkaAvroSerializer \u062a\u063a\u06cc\u06cc\u0631 \u0645\u06cc\u200c\u062f\u0647\u06cc\u062f \u0648 \u0622\u062f\u0631\u0633 Schema Registry \u0631\u0627 \u0628\u0627 \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u0627\u0632 SCHEMA_REGISTRY_URL_CONFIG \u0645\u0634\u062e\u0635 \u0645\u06cc\u200c\u06a9\u0646\u06cc\u062f.<\/span><\/div>\n
\u2022 \u062a\u0639\u0631\u06cc\u0641 \u0645\u0642\u062f\u0627\u0631 \u0642\u0628\u0644\u06cc \u06a9\u0647 \u0627\u0632 \u0646\u0648\u0639 String \u0628\u0648\u062f \u0631\u0627 \u0628\u0647 TempMeasurement \u062a\u063a\u06cc\u06cc\u0631 \u0645\u06cc\u200c\u062f\u0647\u06cc\u062f \u0648 \u0628\u0631\u0627\u06cc producerRecord \u06cc\u06a9 \u0646\u0645\u0648\u0646\u0647 \u062c\u062f\u06cc\u062f \u0627\u0632 TempMeasurement \u0628\u0627 \u062f\u0648 \u067e\u0627\u0631\u0627\u0645\u062a\u0631 measurementValue \u0648 measurerName \u0627\u0632 \u0622\u0631\u06af\u0648\u0645\u0627\u0646\u200c\u0647\u0627\u06cc \u062e\u0637 \u0641\u0631\u0645\u0627\u0646 \u0627\u06cc\u062c\u0627\u062f \u0645\u06cc\u200c\u06a9\u0646\u06cc\u062f.<\/span><\/div>\n
<\/div>\n
\u067e\u0633 \u0627\u0632 \u0627\u0646\u062c\u0627\u0645 \u0627\u06cc\u0646 \u062a\u063a\u06cc\u06cc\u0631\u0627\u062a\u060c \u0641\u0627\u06cc\u0644 \u0631\u0627 \u0630\u062e\u06cc\u0631\u0647 \u06a9\u0631\u062f\u0647 \u0648 \u0622\u0646 \u0631\u0627 \u0628\u0628\u0646\u062f\u06cc\u062f.<\/span><\/div>\n
<\/div>\n
\u0628\u0631\u0627\u06cc \u0627\u06cc\u0646\u06a9\u0647 \u0628\u062a\u0648\u0627\u0646\u06cc\u062f \u062f\u0648 \u067e\u0627\u0631\u0627\u0645\u062a\u0631 \u0631\u0627 \u0628\u0647 \u0627\u0633\u06a9\u0631\u06cc\u067e\u062a run-producer.sh \u0627\u0631\u0633\u0627\u0644 \u06a9\u0646\u06cc\u062f\u060c \u0622\u0646 \u0631\u0627 \u0628\u0631\u0627\u06cc \u0648\u06cc\u0631\u0627\u06cc\u0634 \u0628\u0627\u0632 \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
nano run-producer.sh<\/span><\/div>\n
\u067e\u0627\u0631\u0627\u0645\u062a\u0631 \u0632\u06cc\u0631 \u0631\u0627 \u0628\u0647 \u062f\u0633\u062a\u0648\u0631 \u0627\u0636\u0627\u0641\u0647 \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
java<\/span> -cp<\/span> target\/dokafka-1.0-SNAPSHOT.jar:target\/lib\/* com.dokafka.ProducerDemo $1 $2<\/span><\/div>\n
\u0633\u067e\u0633 \u0641\u0627\u06cc\u0644 \u0631\u0627 \u0630\u062e\u06cc\u0631\u0647 \u06a9\u0631\u062f\u0647 \u0648 \u0622\u0646 \u0631\u0627 \u0628\u0628\u0646\u062f\u06cc\u062f. \u062d\u0627\u0644\u0627 \u0645\u06cc\u200c\u062a\u0648\u0627\u0646\u06cc\u062f \u06cc\u06a9 \u0646\u0645\u0648\u0646\u0647 TempMeasurement \u062a\u0648\u0644\u06cc\u062f \u06a9\u0646\u06cc\u062f \u0628\u0627 \u0627\u062c\u0631\u0627\u06cc \u062f\u0633\u062a\u0648\u0631 \u0632\u06cc\u0631:<\/span><\/div>\n
.\/run-producer.sh 100 sammy<\/span><\/div>\n
\u062f\u0631 \u0627\u06cc\u0646 \u062f\u0633\u062a\u0648\u0631\u060c 100 \u0628\u0647\u200c\u0639\u0646\u0648\u0627\u0646 measurementValue \u0648 sammy \u0628\u0647\u200c\u0639\u0646\u0648\u0627\u0646 measurerName \u0627\u0631\u0633\u0627\u0644 \u0645\u06cc\u200c\u0634\u0648\u062f.<\/span><\/div>\n
<\/div>\n
\u0628\u0647\u200c\u0631\u0648\u0632\u0631\u0633\u0627\u0646\u06cc ConsumerDemo<\/span><\/div>\n
<\/div>\n
\u0628\u0631\u0627\u06cc \u062f\u0631\u06cc\u0627\u0641\u062a \u0634\u06cc\u0621 Avro \u06a9\u0647 \u0628\u0647 \u062a\u0627\u0632\u06af\u06cc \u062a\u0648\u0644\u06cc\u062f \u06a9\u0631\u062f\u0647\u200c\u0627\u06cc\u062f\u060c \u0628\u0627\u06cc\u062f \u06a9\u0644\u0627\u0633 ConsumerDemo \u0631\u0627 \u0628\u0647\u200c\u0631\u0648\u0632\u0631\u0633\u0627\u0646\u06cc \u06a9\u0646\u06cc\u062f. \u0627\u0628\u062a\u062f\u0627 \u0622\u0646 \u0631\u0627 \u0628\u0631\u0627\u06cc \u0648\u06cc\u0631\u0627\u06cc\u0634 \u0628\u0627\u0632 \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
nano src\/main\/java\/com\/dokafka\/ConsumerDemo.java<\/span><\/div>\n
\u06a9\u062a\u0627\u0628\u062e\u0627\u0646\u0647\u200c\u0647\u0627\u06cc KafkaAvroDeserializer \u0648 KafkaAvroDeserializerConfig \u0631\u0627 \u0648\u0627\u0631\u062f \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
import org.apache.kafka.common.serialization.StringDeserializer;<\/span><\/div>\n
import io.confluent.kafka.serializers.KafkaAvroDeserializer;<\/span><\/div>\n
import io.confluent.kafka.serializers.KafkaAvroDeserializerConfig;<\/span><\/div>\n
\u0633\u067e\u0633\u060c \u0645\u062a\u062f main \u0631\u0627 \u0628\u0647 \u0635\u0648\u0631\u062a \u0632\u06cc\u0631 \u062a\u063a\u06cc\u06cc\u0631 \u062f\u0647\u06cc\u062f:<\/span><\/div>\n
String topic =<\/span> “java_demo_avro”;<\/span><\/div>\n
String groupId =<\/span> “group1”;<\/span><\/div>\n
<\/div>\n
Properties properties = new Properties();<\/span><\/div>\n
properties.setProperty(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);<\/span><\/div>\n
properties.setProperty(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName());<\/span><\/div>\n
properties.setProperty(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, KafkaAvroDeserializer.class.getName());<\/span><\/div>\n
properties.setProperty(ConsumerConfig.GROUP_ID_CONFIG, groupId);<\/span><\/div>\n
properties.setProperty(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG,<\/span> “earliest”);<\/span><\/div>\n
properties.setProperty(KafkaAvroDeserializerConfig.SCHEMA_REGISTRY_URL_CONFIG,<\/span> “<\/span>http:\/\/localhost:8081<\/a><\/span>“);<\/span><\/div>\n
properties.setProperty(KafkaAvroDeserializerConfig.SPECIFIC_AVRO_READER_CONFIG,<\/span> “true”);<\/span><\/div>\n
<\/div>\n
final KafkaConsumer<String, TempMeasurement> consumer = new KafkaConsumer<>(properties);<\/span><\/div>\n
consumer.subscribe(Collections.singletonList(topic));<\/span><\/div>\n
<\/div>\n
try {<\/span><\/div>\n
\u00a0 while<\/span> (true)<\/span> {<\/span><\/div>\n
\u00a0 \u00a0 ConsumerRecords<String, TempMeasurement> records = consumer.poll(Duration.ofMillis(100));<\/span><\/div>\n
<\/div>\n
\u00a0 \u00a0 for<\/span> (ConsumerRecord<String,<\/span> TempMeasurement> record: records) {<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 log.info(String.format(“measuredValue: %s, measurerName: %s\\n”,<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0 record.value().getMeasuredValue(),<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0 record.value().getMeasurerName()));<\/span><\/div>\n
\u00a0 \u00a0 }<\/span><\/div>\n
\u00a0 }<\/span><\/div>\n
} catch<\/span> (Exception<\/span> e) {<\/span><\/div>\n
\u00a0 log.error(“An error occurred”, e);<\/span><\/div>\n
} finally {<\/span><\/div>\n
\u00a0 consumer.close();<\/span><\/div>\n
}<\/span><\/div>\n
\u062f\u0631 \u0627\u06cc\u0646\u062c\u0627:<\/span><\/div>\n
\u2022 topic \u0648 \u0622\u062f\u0631\u0633 Schema Registry \u0631\u0627 \u0628\u0647\u200c\u0631\u0648\u0632\u0631\u0633\u0627\u0646\u06cc \u0645\u06cc\u200c\u06a9\u0646\u06cc\u062f.<\/span><\/div>\n
\u2022 deserializer \u0631\u0627 \u0628\u0647 KafkaAvroDeserializer \u062a\u063a\u06cc\u06cc\u0631 \u0645\u06cc\u200c\u062f\u0647\u06cc\u062f.<\/span><\/div>\n
\u2022 \u0628\u0627 \u062a\u0646\u0638\u06cc\u0645 SPECIFIC_AVRO_READER_CONFIG \u0628\u0647 true\u060c \u0634\u0645\u0627 \u0628\u0647 deserializer \u0645\u06cc\u200c\u06af\u0648\u06cc\u06cc\u062f \u06a9\u0647 \u0627\u0634\u06cc\u0627\u0621 \u0648\u0627\u0642\u0639\u06cc \u0627\u0632 \u0646\u0648\u0639 TempMeasurement \u0628\u0631\u06af\u0631\u062f\u0627\u0646\u062f. \u062f\u0631 \u063a\u06cc\u0631 \u0627\u06cc\u0646 \u0635\u0648\u0631\u062a\u060c \u06cc\u06a9 GenericRecord Avro \u06a9\u0647 \u0647\u0646\u0648\u0632 \u0634\u0627\u0645\u0644 \u062a\u0645\u0627\u0645 \u0641\u06cc\u0644\u062f\u0647\u0627 \u0627\u0633\u062a\u060c \u0627\u0645\u0627 \u0646\u0648\u0639\u200c\u06af\u0630\u0627\u0631\u06cc \u0645\u0634\u062e\u0635 \u0646\u062f\u0627\u0631\u062f\u060c \u0628\u0631\u06af\u0631\u062f\u0627\u0646\u062f\u0647 \u062e\u0648\u0627\u0647\u062f \u0634\u062f.<\/span><\/div>\n
<\/div>\n
\u062d\u0627\u0644\u0627 \u0645\u06cc\u200c\u062a\u0648\u0627\u0646\u06cc\u062f \u062f\u0627\u062f\u0647\u200c\u0647\u0627\u06cc Avro \u062a\u0648\u0644\u06cc\u062f \u0634\u062f\u0647 \u0631\u0627 \u062f\u0631\u06cc\u0627\u0641\u062a \u06a9\u0646\u06cc\u062f.<\/span><\/div>\n
\u0633\u067e\u0633\u060c \u0646\u0648\u0639 \u0645\u0642\u062f\u0627\u0631 TempMeasurement \u0631\u0627 \u062f\u0631 \u0633\u0631\u0627\u0633\u0631 \u06a9\u062f \u0628\u0627\u0642\u06cc\u200c\u0645\u0627\u0646\u062f\u0647 \u0627\u0646\u062a\u0634\u0627\u0631 \u0645\u06cc\u200c\u062f\u0647\u06cc\u062f. \u062f\u0631 \u062f\u0627\u062e\u0644 \u062d\u0644\u0642\u0647 for\u060c \u0641\u0631\u0627\u062e\u0648\u0627\u0646\u06cc \u0645\u062a\u062f logging \u0631\u0627 \u0628\u0647\u200c\u0631\u0648\u0632\u0631\u0633\u0627\u0646\u06cc \u0645\u06cc\u200c\u06a9\u0646\u06cc\u062f \u062a\u0627 measurementTemp \u0648 measurementValue \u0631\u0627 \u0628\u0647\u200c\u062f\u0631\u0633\u062a\u06cc \u0646\u0645\u0627\u06cc\u0634 \u062f\u0647\u062f.<\/span><\/div>\n
<\/div>\n
\u0628\u0627 \u062a\u0648\u062c\u0647 \u0628\u0647 \u06cc\u06a9\u067e\u0627\u0631\u0686\u06af\u06cc \u0628\u0627 Schema Registry\u060c \u062a\u0648\u0644\u06cc\u062f\u06a9\u0646\u0646\u062f\u0647<\/span> (producer)<\/span> \u0634\u06cc\u0621 \u0631\u0627 \u0647\u0645\u0631\u0627\u0647 \u0628\u0627 \u0634\u0646\u0627\u0633\u0627\u06cc\u06cc\u200c\u06a9\u0646\u0646\u062f\u0647<\/span> (identifier)<\/span> \u0627\u0633\u06a9\u06cc\u0645\u0627\u06cc \u0622\u0646 \u0628\u0647 topic \u0627\u0631\u0633\u0627\u0644 \u0645\u06cc\u200c\u06a9\u0646\u062f\u060c \u0646\u0647 \u0627\u06cc\u0646\u06a9\u0647 \u062e\u0648\u062f \u0627\u0633\u06a9\u06cc\u0645\u0627\u06cc \u0634\u06cc\u0621 \u0631\u0627 \u0627\u0631\u0633\u0627\u0644 \u06a9\u0646\u062f. \u0645\u0635\u0631\u0641\u200c\u06a9\u0646\u0646\u062f\u0647<\/span> (consumer)<\/span> \u0633\u067e\u0633 \u0622\u0646 \u0627\u0633\u06a9\u06cc\u0645\u0627\u06cc \u06a9\u0627\u0645\u0644 \u0631\u0627 \u0627\u0632 Schema Registry \u062f\u0631\u06cc\u0627\u0641\u062a \u06a9\u0631\u062f\u0647 \u0648 \u0622\u0646 \u0631\u0627 deserializes \u0645\u06cc\u200c\u06a9\u0646\u062f.<\/span><\/div>\n
<\/div>\n
\u067e\u0633 \u0627\u0632 \u0627\u0646\u062c\u0627\u0645 \u062a\u063a\u06cc\u06cc\u0631\u0627\u062a\u060c \u0641\u0627\u06cc\u0644 \u0631\u0627 \u0630\u062e\u06cc\u0631\u0647 \u06a9\u0631\u062f\u0647 \u0648 \u0622\u0646 \u0631\u0627 \u0628\u0628\u0646\u062f\u06cc\u062f. \u0633\u067e\u0633 \u0645\u0635\u0631\u0641\u200c\u06a9\u0646\u0646\u062f\u0647 \u0631\u0627 \u0627\u062c\u0631\u0627 \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
.\/run-consumer.sh<\/span><\/div>\n
\u062e\u0631\u0648\u062c\u06cc \u0622\u062e\u0631 \u0645\u0634\u0627\u0628\u0647 \u0627\u06cc\u0646 \u062e\u0648\u0627\u0647\u062f \u0628\u0648\u062f:<\/span><\/div>\n
[main] INFO com.dokafka.ConsumerDemo – measuredValue: 100.0, measurerName: sammy<\/span><\/div>\n
\u0627\u06cc\u0646 \u0646\u0634\u0627\u0646\u200c\u062f\u0647\u0646\u062f\u0647 \u0627\u06cc\u0646 \u0627\u0633\u062a \u06a9\u0647 \u0645\u0635\u0631\u0641\u200c\u06a9\u0646\u0646\u062f\u0647 Kafka \u067e\u06cc\u0627\u0645 Avro \u0631\u0627 \u0628\u0647\u200c\u062f\u0631\u0633\u062a\u06cc deserialized \u06a9\u0631\u062f\u0647 \u0627\u0633\u062a\u060c \u0647\u0645\u0627\u0646\u0637\u0648\u0631 \u06a9\u0647 \u0627\u0632 \u067e\u06cc\u0627\u0645 log \u0645\u0634\u062e\u0635 \u0627\u0633\u062a.<\/span><\/div>\n
<\/div>\n
\u062f\u0631 \u0627\u06cc\u0646 \u0645\u0631\u062d\u0644\u0647\u060c \u0634\u0645\u0627 \u06a9\u0644\u0627\u0633\u200c\u0647\u0627\u06cc \u062a\u0648\u0644\u06cc\u062f\u06a9\u0646\u0646\u062f\u0647 \u0648 \u0645\u0635\u0631\u0641\u200c\u06a9\u0646\u0646\u062f\u0647 \u062e\u0648\u062f \u0631\u0627 \u0628\u0647\u200c\u0631\u0648\u0632\u0631\u0633\u0627\u0646\u06cc \u06a9\u0631\u062f\u06cc\u062f \u062a\u0627 \u0627\u0632 \u0627\u0634\u06cc\u0627\u0621 Avro \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u06a9\u0646\u0646\u062f. \u062f\u0631 \u0645\u0631\u062d\u0644\u0647 \u0628\u0639\u062f\u060c \u0634\u0645\u0627 \u06cc\u0627\u062f \u062e\u0648\u0627\u0647\u06cc\u062f \u06af\u0631\u0641\u062a \u06a9\u0647 \u0686\u06af\u0648\u0646\u0647 \u0627\u0633\u06a9\u06cc\u0645\u0627\u06cc \u062e\u0648\u062f \u0631\u0627 \u0628\u0647\u200c\u0631\u0648\u0632\u0631\u0633\u0627\u0646\u06cc \u06a9\u0631\u062f\u0647 \u0648 \u0633\u0627\u0632\u06af\u0627\u0631\u06cc \u0622\u0646 \u0631\u0627 \u0628\u0627 Schema Registry \u067e\u06cc\u06af\u06cc\u0631\u06cc \u06a9\u0646\u06cc\u062f.<\/span><\/div>\n
\u0645\u0631\u062d\u0644\u0647 \u06f4 – \u062a\u06a9\u0627\u0645\u0644 \u0627\u0633\u06a9\u06cc\u0645\u0627\u06cc \u062f\u0627\u062f\u0647 \u0648 \u0633\u0627\u0632\u06af\u0627\u0631\u06cc<\/span><\/div>\n
<\/div>\n
\u062f\u0631 \u0627\u06cc\u0646 \u0645\u0631\u062d\u0644\u0647\u060c \u0634\u0645\u0627 \u06cc\u0627\u062f \u062e\u0648\u0627\u0647\u06cc\u062f \u06af\u0631\u0641\u062a \u06a9\u0647 \u0686\u06af\u0648\u0646\u0647 \u0627\u0633\u06a9\u06cc\u0645\u0627\u06cc \u0645\u0648\u062c\u0648\u062f \u0631\u0627 \u0628\u0647\u200c\u0631\u0648\u0632\u0631\u0633\u0627\u0646\u06cc \u06a9\u0646\u06cc\u062f \u0648 \u0627\u06cc\u0646 \u062a\u063a\u06cc\u06cc\u0631\u0627\u062a \u0686\u06af\u0648\u0646\u0647 \u0628\u0631 \u0633\u0627\u0632\u06af\u0627\u0631\u06cc \u0628\u0627 \u0646\u0633\u062e\u0647\u200c\u0647\u0627 \u0648 \u0645\u0634\u062a\u0631\u06cc\u0627\u0646 \u0645\u0648\u062c\u0648\u062f \u062a\u0623\u062b\u06cc\u0631 \u0645\u06cc\u200c\u06af\u0630\u0627\u0631\u0646\u062f.<\/span><\/div>\n
<\/div>\n
\u0639\u0644\u0627\u0648\u0647 \u0628\u0631 \u0630\u062e\u06cc\u0631\u0647 \u0648 \u0646\u0633\u062e\u0647\u200c\u0628\u0646\u062f\u06cc \u0627\u0633\u06a9\u06cc\u0645\u0627\u06cc \u062f\u0627\u062f\u0647\u200c\u0647\u0627 \u0627\u0632 \u0637\u0631\u06cc\u0642 \u0632\u0645\u0627\u0646\u060c Schema Registry \u0628\u0631\u0627\u06cc \u0641\u0639\u0627\u0644\u200c\u0633\u0627\u0632\u06cc \u062a\u06a9\u0627\u0645\u0644 \u0627\u0633\u06a9\u06cc\u0645\u0627\u06cc \u062f\u0627\u062f\u0647 \u0628\u0633\u06cc\u0627\u0631 \u0645\u0647\u0645 \u0627\u0633\u062a. \u0627\u0633\u06a9\u06cc\u0645\u0627\u06cc \u062f\u0627\u062f\u0647 \u0645\u06cc\u200c\u062a\u0648\u0627\u0646\u062f \u062f\u0631 \u0637\u0648\u0644 \u0639\u0645\u0631 \u06cc\u06a9 \u067e\u0631\u0648\u0698\u0647 \u062a\u063a\u06cc\u06cc\u0631 \u06a9\u0646\u062f\u060c \u062f\u0631 \u062d\u0627\u0644\u06cc \u06a9\u0647 \u062f\u0627\u062f\u0647\u200c\u0647\u0627\u06cc \u062a\u0648\u0644\u06cc\u062f\u0634\u062f\u0647 \u0642\u0628\u0644\u0627\u064b \u0646\u0645\u06cc\u200c\u062a\u0648\u0627\u0646\u0646\u062f \u062a\u063a\u06cc\u06cc\u0631 \u06a9\u0646\u0646\u062f.<\/span><\/div>\n
<\/div>\n
Schema Registry \u0645\u0633\u0626\u0648\u0644 \u0645\u062f\u06cc\u0631\u06cc\u062a \u0633\u0627\u0632\u06af\u0627\u0631\u06cc \u0628\u06cc\u0646 \u0646\u0633\u062e\u0647\u200c\u0647\u0627\u06cc \u0645\u062e\u062a\u0644\u0641 \u0627\u0633\u06a9\u06cc\u0645\u0627\u06cc \u062f\u0627\u062f\u0647 \u0627\u0633\u062a \u0648 \u0628\u0647 \u0645\u0635\u0631\u0641\u200c\u06a9\u0646\u0646\u062f\u0647 \u0627\u062c\u0627\u0632\u0647 \u0645\u06cc\u200c\u062f\u0647\u062f \u062a\u0627 \u062f\u0627\u062f\u0647\u200c\u0647\u0627 \u0631\u0627 \u0645\u0637\u0627\u0628\u0642 \u0628\u0627 \u0646\u0633\u062e\u0647 \u062f\u0627\u062e\u0644\u06cc \u0627\u0633\u06a9\u06cc\u0645\u0627\u06cc \u062e\u0648\u062f \u062a\u062c\u0632\u06cc\u0647 \u06a9\u0646\u062f. \u0627\u06cc\u0646 \u0642\u0627\u0628\u0644\u06cc\u062a \u0628\u0647 \u062a\u0648\u0644\u06cc\u062f\u06a9\u0646\u0646\u062f\u06af\u0627\u0646 \u0648 \u0645\u0635\u0631\u0641\u200c\u06a9\u0646\u0646\u062f\u06af\u0627\u0646 \u0627\u062c\u0627\u0632\u0647 \u0645\u06cc\u200c\u062f\u0647\u062f \u06a9\u0647 \u062f\u0631 \u0627\u0631\u062a\u0628\u0627\u0637 \u0628\u0627 \u0646\u0633\u062e\u0647 \u062f\u0642\u06cc\u0642 \u0627\u0633\u06a9\u06cc\u0645\u0627\u06cc \u062e\u0648\u062f \u0647\u0645\u06af\u0627\u0645 \u0646\u0628\u0627\u0634\u0646\u062f\u060c \u0632\u06cc\u0631\u0627 \u0622\u0646\u0647\u0627 \u0645\u06cc\u200c\u062a\u0648\u0627\u0646\u0646\u062f \u062f\u0631 \u06a9\u062f\u0647\u0627\u06cc \u0645\u062e\u062a\u0644\u0641 \u0642\u0631\u0627\u0631 \u062f\u0627\u0634\u062a\u0647 \u0628\u0627\u0634\u0646\u062f.<\/span><\/div>\n
<\/div>\n
\u0627\u0633\u062a\u0631\u0627\u062a\u0698\u06cc\u200c\u0647\u0627\u06cc \u0627\u0635\u0644\u06cc \u0633\u0627\u0632\u06af\u0627\u0631\u06cc \u06a9\u0647 Schema Registry \u0627\u0631\u0627\u0626\u0647 \u0645\u06cc\u200c\u062f\u0647\u062f \u0639\u0628\u0627\u0631\u062a\u0646\u062f \u0627\u0632:<\/span><\/div>\n
\u2022 BACKWARD: \u0627\u0637\u0645\u06cc\u0646\u0627\u0646 \u0645\u06cc\u200c\u062f\u0647\u062f \u06a9\u0647 \u0645\u0635\u0631\u0641\u200c\u06a9\u0646\u0646\u062f\u06af\u0627\u0646 \u0628\u0627 \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u0627\u0632 \u0627\u0633\u06a9\u06cc\u0645\u0627\u06cc \u062c\u062f\u06cc\u062f \u0645\u06cc\u200c\u062a\u0648\u0627\u0646\u0646\u062f \u062f\u0627\u062f\u0647\u200c\u0647\u0627\u06cc\u06cc \u0631\u0627 \u06a9\u0647 \u0628\u0631 \u0627\u0633\u0627\u0633 \u0646\u0633\u062e\u0647 \u0642\u0628\u0644\u06cc \u0627\u06cc\u062c\u0627\u062f \u0634\u062f\u0647\u200c\u0627\u0646\u062f\u060c \u0628\u062e\u0648\u0627\u0646\u0646\u062f.<\/span><\/div>\n
\u2022 FORWARD: \u0628\u0647 \u0627\u06cc\u0646 \u0645\u0639\u0646\u06cc \u06a9\u0647 \u0645\u0635\u0631\u0641\u200c\u06a9\u0646\u0646\u062f\u06af\u0627\u0646 \u0628\u0627 \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u0627\u0632 \u0627\u0633\u06a9\u06cc\u0645\u0627\u06cc \u062c\u062f\u06cc\u062f \u0645\u06cc\u200c\u062a\u0648\u0627\u0646\u0646\u062f \u062f\u0627\u062f\u0647\u200c\u0647\u0627\u06cc\u06cc \u0631\u0627 \u06a9\u0647 \u0628\u0631 \u0627\u0633\u0627\u0633 \u0627\u0633\u06a9\u06cc\u0645\u0627\u06cc \u062c\u062f\u06cc\u062f \u0627\u06cc\u062c\u0627\u062f \u0634\u062f\u0647\u200c\u0627\u0646\u062f\u060c \u0628\u062e\u0648\u0627\u0646\u0646\u062f<\/span> (\u0628\u062f\u0648\u0646<\/span> \u062a\u0636\u0645\u06cc\u0646 \u0628\u0631\u0627\u06cc \u0646\u0633\u062e\u0647\u200c\u0647\u0627\u06cc \u0642\u0628\u0644\u06cc).<\/span><\/div>\n
\u2022 FULL: \u062a\u0631\u06a9\u06cc\u0628\u06cc \u0627\u0632 \u062f\u0648 \u0627\u0633\u062a\u0631\u0627\u062a\u0698\u06cc \u0642\u0628\u0644\u06cc \u0627\u0633\u062a.<\/span><\/div>\n
\u2022 NONE: \u0628\u0647 \u0627\u06cc\u0646 \u0645\u0639\u0646\u06cc \u06a9\u0647 \u0628\u0631\u0631\u0633\u06cc\u200c\u0647\u0627\u06cc \u0633\u0627\u0632\u06af\u0627\u0631\u06cc \u063a\u06cc\u0631\u0641\u0639\u0627\u0644 \u0647\u0633\u062a\u0646\u062f.<\/span><\/div>\n
<\/div>\n
\u0633\u0647 \u0627\u0633\u062a\u0631\u0627\u062a\u0698\u06cc \u0627\u0648\u0644 \u062f\u0627\u0631\u0627\u06cc \u0647\u0645\u062a\u0627\u06cc\u0627\u0646 \u062a\u0631\u0627\u0646\u0632\u06cc\u062a\u06cc<\/span> (\u0645\u062b\u0644<\/span> BACKWARD_TRANSITIVE) \u0647\u0633\u062a\u0646\u062f \u06a9\u0647 \u0645\u0644\u0632\u0645 \u0645\u06cc\u200c\u06a9\u0646\u062f \u0627\u0633\u06a9\u06cc\u0645\u0627\u06cc \u062c\u062f\u06cc\u062f \u0628\u0627 \u062a\u0645\u0627\u0645 \u0646\u0633\u062e\u0647\u200c\u0647\u0627\u06cc \u0642\u0628\u0644\u06cc \u0627\u0633\u06a9\u06cc\u0645\u0627\u06cc \u062f\u0627\u062f\u0647 \u0633\u0627\u0632\u06af\u0627\u0631 \u0628\u0627\u0634\u062f\u060c \u0646\u0647 \u0641\u0642\u0637 \u0646\u0633\u062e\u0647 \u0642\u0628\u0644\u06cc.<\/span><\/div>\n
<\/div>\n
\u0627\u0633\u062a\u0631\u0627\u062a\u0698\u06cc \u067e\u06cc\u0634\u200c\u0641\u0631\u0636 BACKWARD \u0627\u0633\u062a.<\/span><\/div>\n
<\/div>\n
\u0628\u0647\u200c\u0631\u0648\u0632\u0631\u0633\u0627\u0646\u06cc \u0627\u0633\u06a9\u06cc\u0645\u0627\u06cc TempMeasurement<\/span><\/div>\n
<\/div>\n
\u062f\u0631 \u0627\u06cc\u0646 \u0645\u0631\u062d\u0644\u0647\u060c \u0634\u0645\u0627 \u0627\u0633\u06a9\u06cc\u0645\u0627\u06cc TempMeasurement \u0631\u0627 \u0628\u0647\u200c\u0631\u0648\u0632\u0631\u0633\u0627\u0646\u06cc \u0645\u06cc\u200c\u06a9\u0646\u06cc\u062f \u062a\u0627 \u06cc\u06a9 \u0641\u06cc\u0644\u062f \u062c\u062f\u06cc\u062f \u0628\u0647 \u0646\u0627\u0645 measurementDate \u0628\u0631\u0627\u06cc \u0630\u062e\u06cc\u0631\u0647 \u062a\u0627\u0631\u06cc\u062e \u0627\u0646\u062f\u0627\u0632\u0647\u200c\u06af\u06cc\u0631\u06cc \u0627\u0636\u0627\u0641\u0647 \u0634\u0648\u062f.<\/span><\/div>\n
<\/div>\n
\u06f1. \u0641\u0627\u06cc\u0644 \u0627\u0633\u06a9\u06cc\u0645\u0627\u06cc TempMeasurement \u0631\u0627 \u0628\u0631\u0627\u06cc \u0648\u06cc\u0631\u0627\u06cc\u0634 \u0628\u0627\u0632 \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
nano src\/main\/java\/com\/dokafka\/TempMeasurement.avsc<\/span><\/div>\n
\u06f2. \u0622\u0646 \u0631\u0627 \u0628\u0647 \u0634\u06a9\u0644 \u0632\u06cc\u0631 \u062a\u063a\u06cc\u06cc\u0631 \u062f\u0647\u06cc\u062f:<\/span><\/div>\n
{<\/span><\/div>\n
\u00a0<\/span> “namespace”:<\/span> “com.dokafka”,<\/span><\/div>\n
\u00a0<\/span> “name”:<\/span> “TempMeasurement”,<\/span><\/div>\n
\u00a0<\/span> “type”:<\/span> “record”,<\/span><\/div>\n
\u00a0<\/span> “fields”:<\/span> [<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 {<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u00a0<\/span> “name”:<\/span> “measuredValue”,<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u00a0<\/span> “type”:<\/span> “double”<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 },<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 {<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u00a0<\/span> “name”:<\/span> “measurerName”,<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u00a0<\/span> “type”:<\/span> “string”<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 },<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 {<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u00a0<\/span> “name”:<\/span> “measurementDate”,<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u00a0<\/span> “type”:<\/span> “string”<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 }<\/span><\/div>\n
\u00a0 ]<\/span><\/div>\n
}<\/span><\/div>\n
\u06f3. \u0634\u0645\u0627 \u06cc\u06a9 \u0641\u06cc\u0644\u062f \u062c\u062f\u06cc\u062f \u0628\u0647 \u0646\u0627\u0645 measurementDate \u062a\u0639\u0631\u06cc\u0641 \u06a9\u0631\u062f\u0647\u200c\u0627\u06cc\u062f \u06a9\u0647 \u062a\u0627\u0631\u06cc\u062e \u0627\u0646\u062f\u0627\u0632\u0647\u200c\u06af\u06cc\u0631\u06cc \u0631\u0627 \u0628\u0647\u200c\u0635\u0648\u0631\u062a \u0645\u062a\u0646\u06cc \u0630\u062e\u06cc\u0631\u0647 \u062e\u0648\u0627\u0647\u062f \u06a9\u0631\u062f. \u0641\u0627\u06cc\u0644 \u0631\u0627 \u0630\u062e\u06cc\u0631\u0647 \u0648 \u0628\u0633\u062a\u0647 \u06a9\u0646\u06cc\u062f.<\/span><\/div>\n
<\/div>\n
\u06f4. \u0628\u0631\u0627\u06cc \u0627\u06cc\u062c\u0627\u062f \u0646\u0633\u062e\u0647 \u062c\u062f\u06cc\u062f \u0627\u0632 \u0627\u0633\u06a9\u06cc\u0645\u0627\u06cc \u0628\u0647\u200c\u0631\u0648\u0632\u0631\u0633\u0627\u0646\u06cc\u200c\u0634\u062f\u0647 \u062f\u0631 Schema Registry\u060c \u062f\u0633\u062a\u0648\u0631 \u0632\u06cc\u0631 \u0631\u0627 \u0627\u062c\u0631\u0627 \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
curl<\/span> -X<\/span> POST<\/span> -H<\/span> “Content-Type:<\/span> application\/vnd.schemaregistry.v1+json” \\<\/span><\/div>\n
\u00a0 \u00a0<\/span> -d<\/span> “$(jq<\/span> -R<\/span> -s<\/span> ‘{“schema”:<\/span> .}’ < src\/main\/java\/com\/dokafka\/TempMeasurement.avsc)” \\<\/span><\/div>\n
\u00a0 \u00a0 <\/span>http:\/\/localhost:8081\/subjects\/TempMeasurement\/versions<\/a><\/span><\/div>\n
\u06f5. \u062f\u0631 \u0627\u06cc\u0646 \u0645\u0631\u062d\u0644\u0647\u060c \u062e\u0637\u0627\u06cc \u0632\u06cc\u0631 \u0628\u0647 \u0634\u0645\u0627 \u0646\u0645\u0627\u06cc\u0634 \u062f\u0627\u062f\u0647 \u062e\u0648\u0627\u0647\u062f \u0634\u062f:<\/span><\/div>\n
{<\/span><\/div>\n
\u00a0<\/span> “error_code”:<\/span> 409,<\/span><\/div>\n
\u00a0<\/span> “message”:<\/span> “Schema<\/span> being registered is incompatible with an earlier schema for subject \\”TempMeasurement\\”, details:<\/span> [{errorType:’READER_FIELD_MISSING_DEFAULT_VALUE’,<\/span> description:’The field<\/span> ‘measurementDate’<\/span> at path<\/span> ‘\/fields\/2’<\/span> in the new schema has no default value and is missing in the old schema’, additionalInfo:’measurementDate’}, {oldSchemaVersion: 1}, {oldSchema:<\/span> ‘{\\”type\\”:\\”record\\”,\\”name\\”:\\”TempMeasurement\\”,\\”namespace\\”:\\”com.dokafka\\”,\\”fields\\”:[{\\”name\\”:\\”measuredValue\\”,\\”type\\”:\\”double\\”},{\\”name\\”:\\”measurerName\\”,\\”type\\”:\\”string\\”}]}’},<\/span> {validateFields:<\/span> ‘false’,<\/span> compatibility:<\/span> ‘BACKWARD’}]”<\/span><\/div>\n
}<\/span><\/div>\n
\u0627\u06cc\u0646 \u062e\u0637\u0627 \u0646\u0634\u0627\u0646 \u0645\u06cc\u200c\u062f\u0647\u062f \u06a9\u0647 \u0627\u0633\u06a9\u06cc\u0645\u0627\u06cc \u062c\u062f\u06cc\u062f \u0628\u0627 \u0646\u0633\u062e\u0647 \u0642\u0628\u0644\u06cc \u0633\u0627\u0632\u06af\u0627\u0631 \u0646\u06cc\u0633\u062a \u0632\u06cc\u0631\u0627 \u0641\u06cc\u0644\u062f measurementDate \u062c\u062f\u06cc\u062f \u0627\u0633\u062a \u0648 \u0645\u0642\u062f\u0627\u0631\u06cc \u067e\u06cc\u0634\u200c\u0641\u0631\u0636 \u0646\u062f\u0627\u0631\u062f. \u0627\u06cc\u0646 \u0631\u0641\u062a\u0627\u0631 \u0628\u0627\u0639\u062b \u0645\u06cc\u200c\u0634\u0648\u062f \u06a9\u0647 \u0645\u0635\u0631\u0641\u200c\u06a9\u0646\u0646\u062f\u06af\u0627\u0646 \u0628\u0627 \u0627\u0633\u06a9\u06cc\u0645\u0627\u06cc \u062c\u062f\u06cc\u062f \u0646\u062a\u0648\u0627\u0646\u0646\u062f \u062f\u0627\u062f\u0647\u200c\u0647\u0627\u06cc\u06cc \u0631\u0627 \u06a9\u0647 \u0628\u0627 \u0627\u0633\u06a9\u06cc\u0645\u0627\u06cc \u0642\u0628\u0644\u06cc \u0627\u06cc\u062c\u0627\u062f \u0634\u062f\u0647\u200c\u0627\u0646\u062f\u060c \u0628\u062e\u0648\u0627\u0646\u0646\u062f.<\/span><\/div>\n
<\/div>\n
\u06f6. \u0628\u0631\u0627\u06cc \u0631\u0641\u0639 \u0627\u06cc\u0646 \u0645\u0634\u06a9\u0644\u060c \u0641\u0627\u06cc\u0644 \u0631\u0627 \u062f\u0648\u0628\u0627\u0631\u0647 \u0628\u0627\u0632 \u06a9\u0646\u06cc\u062f \u0648 \u062e\u0637\u06cc \u0628\u0631\u0627\u06cc \u0645\u0642\u062f\u0627\u0631 \u067e\u06cc\u0634\u200c\u0641\u0631\u0636 \u0628\u0647 \u0641\u06cc\u0644\u062f measurementDate \u0627\u0636\u0627\u0641\u0647 \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
{<\/span><\/div>\n
\u00a0<\/span> “namespace”:<\/span> “com.dokafka”,<\/span><\/div>\n
\u00a0<\/span> “name”:<\/span> “TempMeasurement”,<\/span><\/div>\n
\u00a0<\/span> “type”:<\/span> “record”,<\/span><\/div>\n
\u00a0<\/span> “fields”:<\/span> [<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 {<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u00a0<\/span> “name”:<\/span> “measuredValue”,<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u00a0<\/span> “type”:<\/span> “double”<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 },<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 {<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u00a0<\/span> “name”:<\/span> “measurerName”,<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u00a0<\/span> “type”:<\/span> “string”<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 },<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 {<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u00a0<\/span> “name”:<\/span> “measurementDate”,<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u00a0<\/span> “type”:<\/span> “string”,<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u00a0<\/span> “default”:<\/span> “”<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 }<\/span><\/div>\n
\u00a0 ]<\/span><\/div>\n
}<\/span><\/div>\n
\u06f7. \u067e\u0633 \u0627\u0632 \u0630\u062e\u06cc\u0631\u0647 \u0648 \u0628\u0633\u062a\u0646 \u0641\u0627\u06cc\u0644\u060c \u062f\u0648\u0628\u0627\u0631\u0647 \u062f\u0633\u062a\u0648\u0631 \u0627\u0631\u0633\u0627\u0644 \u0627\u0633\u06a9\u06cc\u0645\u0627\u06cc \u062c\u062f\u06cc\u062f \u0631\u0627 \u0627\u062c\u0631\u0627 \u06a9\u0646\u06cc\u062f. \u062e\u0631\u0648\u062c\u06cc \u0628\u0647\u200c\u0635\u0648\u0631\u062a \u0632\u06cc\u0631 \u062e\u0648\u0627\u0647\u062f \u0628\u0648\u062f:<\/span><\/div>\n
{“id”:2}<\/span><\/div>\n
Schema Registry \u0646\u0633\u062e\u0647 \u062f\u0648\u0645 \u0627\u0633\u06a9\u06cc\u0645\u0627\u06cc \u062f\u0627\u062f\u0647 \u0631\u0627 \u067e\u0630\u06cc\u0631\u0641\u062a\u0647 \u0648 \u0634\u0646\u0627\u0633\u0647 \u06f2 \u0631\u0627 \u0628\u0647 \u0622\u0646 \u0627\u062e\u062a\u0635\u0627\u0635 \u062f\u0627\u062f\u0647 \u0627\u0633\u062a.<\/span><\/div>\n
<\/div>\n
\u06f8. \u0628\u0631\u0627\u06cc \u062f\u0631\u06cc\u0627\u0641\u062a \u0646\u0633\u062e\u0647 \u0627\u0648\u0644\u060c \u062f\u0633\u062a\u0648\u0631 \u0632\u06cc\u0631 \u0631\u0627 \u0627\u062c\u0631\u0627 \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
curl<\/span> -X<\/span> GET <\/span>http:\/\/localhost:8081\/subjects\/TempMeasurement\/versions\/1<\/a><\/span><\/div>\n
\u06f9. \u062e\u0631\u0648\u062c\u06cc \u0628\u0647\u200c\u0635\u0648\u0631\u062a \u0632\u06cc\u0631 \u062e\u0648\u0627\u0647\u062f \u0628\u0648\u062f:<\/span><\/div>\n
{<\/span><\/div>\n
\u00a0<\/span> “subject”:<\/span> “TempMeasurement”,<\/span><\/div>\n
\u00a0<\/span> “version”:<\/span> 1,<\/span><\/div>\n
\u00a0<\/span> “id”:<\/span> 1,<\/span><\/div>\n
\u00a0<\/span> “schema”:<\/span> “{\\”type\\”:\\”record\\”,\\”name\\”:\\”TempMeasurement\\”,\\”namespace\\”:\\”com.dokafka\\”,\\”fields\\”:[{\\”name\\”:\\”measuredValue\\”,\\”type\\”:\\”double\\”},{\\”name\\”:\\”measurerName\\”,\\”type\\”:\\”string\\”}]}”<\/span><\/div>\n
}<\/span><\/div>\n
\u06f1\u06f0. \u0628\u0631\u0627\u06cc \u0645\u0634\u0627\u0647\u062f\u0647 \u0647\u0645\u0647 \u0646\u0633\u062e\u0647\u200c\u0647\u0627\u060c \u062f\u0633\u062a\u0648\u0631 \u0632\u06cc\u0631 \u0631\u0627 \u0627\u062c\u0631\u0627 \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
curl<\/span> -X<\/span> GET <\/span>http:\/\/localhost:8081\/subjects\/TempMeasurement\/versions<\/a><\/span><\/div>\n
\u062e\u0631\u0648\u062c\u06cc \u0628\u0647\u200c\u0635\u0648\u0631\u062a \u0632\u06cc\u0631 \u062e\u0648\u0627\u0647\u062f \u0628\u0648\u062f:<\/span><\/div>\n
[1, 2]<\/span><\/div>\n
\u062a\u063a\u06cc\u06cc\u0631 \u0627\u0633\u062a\u0631\u0627\u062a\u0698\u06cc \u0633\u0627\u0632\u06af\u0627\u0631\u06cc<\/span><\/div>\n
<\/div>\n
\u0628\u0631\u0627\u06cc \u062a\u063a\u06cc\u06cc\u0631 \u0627\u0633\u062a\u0631\u0627\u062a\u0698\u06cc \u0633\u0627\u0632\u06af\u0627\u0631\u06cc\u060c \u062f\u0633\u062a\u0648\u0631 \u0632\u06cc\u0631 \u0631\u0627 \u0627\u062c\u0631\u0627 \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
curl<\/span> -X<\/span> PUT<\/span> -H<\/span> “Content-Type:<\/span> application\/vnd.schemaregistry.v1+json” \\<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 <\/span>\u00a0<\/span>–data<\/span> ‘{“compatibility”:<\/span> “BACKWARD_TRANSITIVE”}’<\/span> \\<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0<\/span>http:\/\/localhost:8081\/config\/TempMeasurements<\/a><\/span><\/div>\n
\u062e\u0631\u0648\u062c\u06cc \u0628\u0647\u200c\u0635\u0648\u0631\u062a \u0632\u06cc\u0631 \u062e\u0648\u0627\u0647\u062f \u0628\u0648\u062f:<\/span><\/div>\n
{“compatibility”:”BACKWARD_TRANSITIVE”}<\/span><\/div>\n
\u067e\u0627\u06a9\u200c\u0633\u0627\u0632\u06cc \u0645\u0646\u0627\u0628\u0639 Docker Compose<\/span><\/div>\n
<\/div>\n
\u0628\u0631\u0627\u06cc \u0627\u0632 \u0628\u06cc\u0646 \u0628\u0631\u062f\u0646 \u0645\u0646\u0627\u0628\u0639 Docker Compose\u060c \u062f\u0633\u062a\u0648\u0631 \u0632\u06cc\u0631 \u0631\u0627 \u0627\u062c\u0631\u0627 \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
docker-compose<\/span> -f<\/span> schema-registry-compose.yaml down<\/span><\/div>\n
<\/div>\n
\u062f\u0631 \u0627\u06cc\u0646 \u0645\u0631\u062d\u0644\u0647\u060c \u0634\u0645\u0627 \u0627\u0633\u06a9\u06cc\u0645\u0627\u06cc TempMeasurement \u0631\u0627 \u0645\u0637\u0627\u0628\u0642 \u0628\u0627 \u0627\u0633\u062a\u0631\u0627\u062a\u0698\u06cc \u0633\u0627\u0632\u06af\u0627\u0631\u06cc BACKWARD \u0628\u0647\u200c\u0631\u0648\u0632\u0631\u0633\u0627\u0646\u06cc \u06a9\u0631\u062f\u0647 \u0648 \u0622\u0646 \u0631\u0627 \u062f\u0631 Schema Registry \u0645\u0646\u062a\u0634\u0631 \u06a9\u0631\u062f\u06cc\u062f.<\/span><\/div>\n
<\/div>\n
\u0646\u062a\u06cc\u062c\u0647\u200c\u06af\u06cc\u0631\u06cc<\/span><\/div>\n
<\/div>\n
\u062f\u0631 \u0627\u06cc\u0646 \u0645\u0642\u0627\u0644\u0647\u060c \u0634\u0645\u0627 \u06a9\u0644\u0627\u0633\u200c\u0647\u0627\u06cc ProducerDemo \u0648 ConsumerDemo \u062e\u0648\u062f \u0631\u0627 \u06af\u0633\u062a\u0631\u0634 \u062f\u0627\u062f\u06cc\u062f \u062a\u0627 \u0627\u0634\u06cc\u0627\u06cc TempMeasurement \u0631\u0627 \u06a9\u0647 \u0628\u0627 \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u0627\u0632 Apache Avro \u0633\u0631\u06cc\u0627\u0644\u06cc\u0632\u0647 \u0634\u062f\u0647\u200c\u0627\u0646\u062f\u060c \u062a\u0648\u0644\u06cc\u062f \u0648 \u0645\u0635\u0631\u0641 \u06a9\u0646\u06cc\u062f. \u0647\u0645\u0686\u0646\u06cc\u0646 \u06cc\u0627\u062f \u06af\u0631\u0641\u062a\u06cc\u062f \u06a9\u0647 \u0686\u06af\u0648\u0646\u0647 \u0627\u0632 Schema Registry \u0628\u0631\u0627\u06cc \u0630\u062e\u06cc\u0631\u0647\u200c\u0633\u0627\u0632\u06cc \u0648 \u062a\u06a9\u0627\u0645\u0644 \u0627\u0633\u06a9\u06cc\u0645\u0627\u06cc \u062f\u0627\u062f\u0647 \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u06a9\u0646\u06cc\u062f \u0648 \u0645\u0634\u062a\u0631\u06cc\u0627\u0646 Kafka \u062e\u0648\u062f \u0631\u0627 \u0628\u0647 \u0622\u0646 \u0645\u062a\u0635\u0644 \u06a9\u0646\u06cc\u062f.<\/span><\/div>\n
<\/div>","protected":false},"excerpt":{"rendered":"

\u0645\u0642\u062f\u0645\u0647 \u0628\u0627 \u0631\u0634\u062f \u06a9\u0633\u0628\u200c\u0648\u06a9\u0627\u0631\u0647\u0627\u060c \u062d\u0641\u0638 \u0633\u0627\u0632\u06af\u0627\u0631\u06cc \u0628\u06cc\u0646 \u0641\u0631\u0645\u062a\u200c\u0647\u0627\u06cc \u062f\u0627\u062f\u0647\u200c\u0627\u06cc \u062f\u0631 \u0647\u0646\u06af\u0627\u0645 \u0627\u0633\u062a\u0631\u06cc\u0645 \u0631\u0648\u06cc\u062f\u0627\u062f\u0647\u0627 \u0627\u0647\u0645\u06cc\u062a \u0632\u06cc\u0627\u062f\u06cc \u062f\u0627\u0631\u062f. \u062f\u0627\u062f\u0647\u200c\u0647\u0627\u06cc \u0630\u062e\u06cc\u0631\u0647\u200c\u0634\u062f\u0647 \u062f\u0631 \u0645\u0648\u0636\u0648\u0639\u0627\u062a Apache Kafka \u062a\u063a\u06cc\u06cc\u0631\u0646\u0627\u067e\u0630\u06cc\u0631 \u0647\u0633\u062a\u0646\u062f \u0648 \u0646\u0645\u06cc\u200c\u062a\u0648\u0627\u0646 \u0622\u0646\u0647\u0627 \u0631\u0627 \u0628\u0647\u200c\u0637\u0648\u0631 \u0628\u0627\u0632\u06af\u0634\u062a\u06cc \u0628\u0631\u0627\u06cc \u062a\u0637\u0628\u06cc\u0642 \u0628\u0627 \u0646\u06cc\u0627\u0632\u0647\u0627\u06cc \u0641\u0639\u0644\u06cc \u062a\u063a\u06cc\u06cc\u0631 \u062f\u0627\u062f. \u0645\u0642\u0627\u0628\u0644\u0647 \u0628\u0627 \u0627\u06cc\u0646 \u0645\u0634\u06a9\u0644 \u0632\u0645\u0627\u0646\u06cc \u06a9\u0647 \u062a\u063a\u06cc\u06cc\u0631\u0627\u062a \u0632\u06cc\u0627\u062f\u06cc \u062f\u0631 \u0627\u0633\u06a9\u06cc\u0645\u0627 \u0648\u062c\u0648\u062f \u062f\u0627\u0634\u062a\u0647 \u0628\u0627\u0634\u062f\u060c \u0645\u06cc\u200c\u062a\u0648\u0627\u0646\u062f \u0686\u0627\u0644\u0634\u200c\u0628\u0631\u0627\u0646\u06af\u06cc\u0632 \u0628\u0627\u0634\u062f. Apache Avro […]<\/p>\n","protected":false},"author":1,"featured_media":5387,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"om_disable_all_campaigns":false,"_monsterinsights_skip_tracking":false,"yasr_overall_rating":0,"yasr_post_is_review":"","yasr_auto_insert_disabled":"","yasr_review_type":"","footnotes":""},"categories":[131],"tags":[415,414],"class_list":["post-5386","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-131","tag-confluent-schema-registry","tag-kafka"],"aioseo_notices":[],"yasr_visitor_votes":{"stars_attributes":{"read_only":false,"span_bottom":false},"number_of_votes":0,"sum_votes":0},"_links":{"self":[{"href":"https:\/\/parmin.cloud\/blog\/wp-json\/wp\/v2\/posts\/5386","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/parmin.cloud\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/parmin.cloud\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/parmin.cloud\/blog\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/parmin.cloud\/blog\/wp-json\/wp\/v2\/comments?post=5386"}],"version-history":[{"count":1,"href":"https:\/\/parmin.cloud\/blog\/wp-json\/wp\/v2\/posts\/5386\/revisions"}],"predecessor-version":[{"id":5389,"href":"https:\/\/parmin.cloud\/blog\/wp-json\/wp\/v2\/posts\/5386\/revisions\/5389"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/parmin.cloud\/blog\/wp-json\/wp\/v2\/media\/5387"}],"wp:attachment":[{"href":"https:\/\/parmin.cloud\/blog\/wp-json\/wp\/v2\/media?parent=5386"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/parmin.cloud\/blog\/wp-json\/wp\/v2\/categories?post=5386"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/parmin.cloud\/blog\/wp-json\/wp\/v2\/tags?post=5386"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}