{"id":396864,"date":"2024-06-29T13:06:10","date_gmt":"2024-06-29T13:06:10","guid":{"rendered":"http:\/\/savepearlharbor.com\/?p=396864"},"modified":"-0001-11-30T00:00:00","modified_gmt":"2024-06-29T13:06:10","slug":"","status":"publish","type":"post","link":"https:\/\/savepearlharbor.com\/?p=396864","title":{"rendered":"<span>Schema Registry \u0441 Protobuf \u0432 Kafka \u2014 \u0437\u0430\u0447\u0435\u043c \u043e\u043d\u043e \u043d\u0430\u0434\u043e?<\/span>"},"content":{"rendered":"<div><!--[--><!--]--><\/div>\n<div id=\"post-content-body\">\n<div>\n<div class=\"article-formatted-body article-formatted-body article-formatted-body_version-2\">\n<div xmlns=\"http:\/\/www.w3.org\/1999\/xhtml\">\n<p>\u0412\u0441\u0435\u043c \u043f\u0440\u0438\u0432\u0435\u0442. \u041c\u0435\u043d\u044f \u0437\u043e\u0432\u0443\u0442 \u041d\u0438\u043d\u0430 \u041f\u0430\u043a\u0448\u0438\u043d\u0430, \u044f \u0440\u0430\u0437\u0440\u0430\u0431\u043e\u0442\u0447\u0438\u043a \u0432\u00a0\u043e\u0442\u0434\u0435\u043b\u0435 \u0420\u0430\u0437\u0440\u0430\u0431\u043e\u0442\u043a\u0438 \u0438 \u0443\u043f\u0440\u0430\u0432\u043b\u0435\u043d\u0438\u044f \u0446\u0438\u0444\u0440\u043e\u0432\u044b\u043c\u0438 \u043f\u0440\u043e\u0434\u0443\u043a\u0442\u0430\u043c\u0438 \u0438 \u0447\u0430\u0441\u0442\u044c \u043e\u043f\u0435\u0440\u0430\u0446\u0438\u043e\u043d\u043d\u043e\u0439 \u043a\u043e\u043c\u0430\u043d\u0434\u044b \u0432\u00a0\u0441\u0435\u0440\u0432\u0438\u0441\u0435 \u0434\u043e\u0441\u0442\u0430\u0432\u043a\u0438 \u043f\u0440\u043e\u0434\u0443\u043a\u0442\u043e\u0432 \u00ab\u041b\u0435\u043d\u0442\u0430 \u041e\u043d\u043b\u0430\u0439\u043d\u00bb. \u041d\u0430\u0448 \u0441\u0442\u0435\u043a PHP + Python + Go.<\/p>\n<p>\u041d\u0435\u0434\u0430\u0432\u043d\u043e \u044f \u0441\u0442\u043e\u043b\u043a\u043d\u0443\u043b\u0430\u0441\u044c \u0441\u00a0\u0434\u043e\u0432\u043e\u043b\u044c\u043d\u043e \u0442\u0440\u0438\u0432\u0438\u0430\u043b\u044c\u043d\u043e\u0439 \u0437\u0430\u0434\u0430\u0447\u0435\u0439: \u043d\u0443\u0436\u043d\u043e\u00a0\u0431\u044b\u043b\u043e \u0430\u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u043e \u043f\u043e\u043b\u0443\u0447\u0430\u0442\u044c \u0431\u043e\u043b\u044c\u0448\u043e\u0435 \u043a\u043e\u043b\u0438\u0447\u0435\u0441\u0442\u0432\u043e \u0434\u0430\u043d\u043d\u044b\u0445 \u0438\u0437\u00a0\u0434\u0440\u0443\u0433\u043e\u0433\u043e \u0441\u0435\u0440\u0432\u0438\u0441\u0430. \u0412\u00a0\u043a\u0430\u0447\u0435\u0441\u0442\u0432\u0435 \u0438\u043d\u0441\u0442\u0440\u0443\u043c\u0435\u043d\u0442\u0430 \u043e\u0431\u043c\u0435\u043d\u0430 \u0434\u0430\u043d\u043d\u044b\u043c\u0438 \u0441\u043e\u0432\u043c\u0435\u0441\u0442\u043d\u043e \u0441\u00a0\u043a\u043e\u043c\u0430\u043d\u0434\u043e\u0439 TMS, \u043a\u043e\u0442\u043e\u0440\u0430\u044f \u043e\u0442\u0432\u0435\u0447\u0430\u0435\u0442 \u0437\u0430\u00a0\u0443\u043f\u0440\u0430\u0432\u043b\u0435\u043d\u0438\u0435 \u0440\u0430\u0431\u043e\u0442\u043e\u0439 \u0441\u0431\u043e\u0440\u0449\u0438\u043a\u043e\u0432 \u0438 \u043a\u0443\u0440\u044c\u0435\u0440\u043e\u0432,\u00a0\u0431\u044b\u043b\u043e \u0440\u0435\u0448\u0435\u043d\u043e \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u044c \u0431\u0440\u043e\u043a\u0435\u0440 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439 Kafka.<\/p>\n<p>\u0422\u0430\u043a\u0436\u0435, \u043c\u0435\u0436\u0434\u0443 \u0440\u0430\u0437\u043b\u0438\u0447\u043d\u044b\u043c\u0438 \u043f\u0440\u043e\u0434\u0443\u043a\u0442\u043e\u0432\u044b\u043c\u0438 \u043a\u043e\u043c\u0430\u043d\u0434\u0430\u043c\u0438 \u043d\u0430\u0448\u0435\u0433\u043e \u0441\u0435\u0440\u0432\u0438\u0441\u0430 \u0441\u0443\u0449\u0435\u0441\u0442\u0432\u043e\u0432\u0430\u043b\u0430 \u0434\u043e\u0433\u043e\u0432\u043e\u0440\u0435\u043d\u043d\u043e\u0441\u0442\u044c \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u044c Kafka \u0432\u043c\u0435\u0441\u0442\u0435 \u0441\u00a0Schema Registry \u0438 Protobuf \u0432\u00a0\u043a\u0430\u0447\u0435\u0441\u0442\u0432\u0435 \u0444\u043e\u0440\u043c\u0430\u0442\u0430 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439.<\/p>\n<p>\u0421\u043e \u0441\u0442\u043e\u0440\u043e\u043d\u044b \u043d\u0430\u0448\u0435\u0439 \u043a\u043e\u043c\u0430\u043d\u0434\u044b \u043c\u044b \u0432\u043f\u0435\u0440\u0432\u044b\u0435 \u0440\u0435\u0430\u043b\u0438\u0437\u043e\u0432\u0430\u043b\u0438 \u0442\u0430\u043a\u0443\u044e \u0441\u0432\u044f\u0437\u043a\u0443, \u043f\u043e\u044d\u0442\u043e\u043c\u0443 \u0432\u00a0\u044d\u0442\u043e\u0439 \u0441\u0442\u0430\u0442\u044c\u0435 \u0445\u043e\u0447\u0443 \u043f\u043e\u0434\u0435\u043b\u0438\u0442\u044c\u0441\u044f \u0441\u0432\u043e\u0438\u043c \u043e\u043f\u044b\u0442\u043e\u043c \u043d\u0430\u043f\u0438\u0441\u0430\u043d\u0438\u044f \u043f\u0440\u043e\u0434\u044e\u0441\u0435\u0440\u0430 \u0438 \u043a\u043e\u043d\u0441\u044c\u044e\u043c\u0435\u0440\u0430 \u0441\u00a0\u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u043d\u0438\u0435\u043c Schema Registry \u043d\u0430\u00a0Go, \u0430\u00a0\u0442\u0430\u043a\u0436\u0435 \u0440\u0430\u0441\u0441\u043a\u0430\u0437\u0430\u0442\u044c \u043e\u00a0\u043f\u043e\u0434\u0432\u043e\u0434\u043d\u044b\u0445 \u043a\u0430\u043c\u043d\u044f\u0445, \u0441\u00a0\u043a\u043e\u0442\u043e\u0440\u044b\u043c\u0438 \u0432\u044b \u043c\u043e\u0436\u0435\u0442\u0435 \u0441\u0442\u043e\u043b\u043a\u043d\u0443\u0442\u044c\u0441\u044f.<\/p>\n<h2>\u0427\u0442\u043e \u0442\u0430\u043a\u043e\u0435 Schema Registry?<\/h2>\n<p>\u0415\u0441\u043b\u0438 \u043e\u0447\u0435\u043d\u044c \u0443\u043f\u0440\u043e\u0441\u0442\u0438\u0442\u044c\u00a0\u2014 <a href=\"https:\/\/docs.confluent.io\/platform\/current\/schema-registry\/\"><u>Schema Registry<\/u><\/a> (\u0434\u0430\u043b\u0435\u0435 SR)\u00a0\u2014 \u044d\u0442\u043e \u043e\u0442\u0434\u0435\u043b\u044c\u043d\u044b\u0439 \u043e\u0442\u00a0Kafka \u043a\u043e\u043c\u043f\u043e\u043d\u0435\u043d\u0442, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u044f\u0432\u043b\u044f\u0435\u0442\u0441\u044f \u0441\u0435\u0440\u0432\u0438\u0441\u043d\u044b\u043c \u0441\u043b\u043e\u0435\u043c \u0434\u043b\u044f\u00a0\u043c\u0435\u0442\u0430\u0434\u0430\u043d\u043d\u044b\u0445 Kafka \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439.<\/p>\n<p>\u041d\u0430\u00a0\u0440\u0438\u0441\u0443\u043d\u043a\u0435 1\u00a0\u2014 \u0441\u0445\u0435\u043c\u0430 \u0440\u0430\u0431\u043e\u0442\u044b SR \u0438\u0437\u00a0\u043e\u0444\u0438\u0446\u0438\u0430\u043b\u044c\u043d\u043e\u0439 \u0434\u043e\u043a\u0443\u043c\u0435\u043d\u0442\u0430\u0446\u0438\u0438 \u043e\u0442\u00a0Confluentic.<\/p>\n<figure class=\"full-width\"><img loading=\"lazy\" decoding=\"async\" src=\"https:\/\/habrastorage.org\/r\/w1560\/getpro\/habr\/upload_files\/057\/470\/16c\/05747016c1e33e6aebfcc1968a44bedc.png\" alt=\"\u0420\u0438\u0441 1. \u041a\u0430\u043a \u0440\u0430\u0431\u043e\u0442\u0430\u0435\u0442 Schema Registry\" title=\"\u0420\u0438\u0441 1. \u041a\u0430\u043a \u0440\u0430\u0431\u043e\u0442\u0430\u0435\u0442 Schema Registry\" width=\"1001\" height=\"566\" data-src=\"https:\/\/habrastorage.org\/getpro\/habr\/upload_files\/057\/470\/16c\/05747016c1e33e6aebfcc1968a44bedc.png\"\/><figcaption>\u0420\u0438\u0441 1. \u041a\u0430\u043a \u0440\u0430\u0431\u043e\u0442\u0430\u0435\u0442 Schema Registry<\/figcaption><\/figure>\n<p>SR, \u043f\u043e\u00a0\u0441\u0443\u0442\u0438 \u044f\u0432\u043b\u044f\u0435\u0442\u0441\u044f \u043f\u0440\u043e\u0441\u043b\u043e\u0439\u043a\u043e\u0439 \u043c\u0435\u0436\u0434\u0443 Kafka \u0438 \u043a\u043b\u0438\u0435\u043d\u0442\u0441\u043a\u0438\u043c \u043f\u0440\u043e\u0434\u044e\u0441\u0435\u0440\u043e\u043c\/\u043a\u043e\u043d\u0441\u044c\u044e\u043c\u0435\u0440\u043e\u043c, \u0430\u00a0\u0433\u043b\u0430\u0432\u043d\u0430\u044f \u0437\u0430\u0434\u0430\u0447\u0430 \u043a\u043b\u0438\u0435\u043d\u0442\u0430 \u0438 \u0441\u0435\u0440\u0432\u0435\u0440\u0430 SR\u00a0\u2014 \u043f\u043e\u0434\u0434\u0435\u0440\u0436\u0438\u0432\u0430\u0442\u044c \u0441\u043e\u0432\u043c\u0435\u0441\u0442\u0438\u043c\u043e\u0441\u0442\u044c \u043c\u0435\u0436\u0434\u0443 \u0440\u0430\u0437\u043b\u0438\u0447\u043d\u044b\u043c\u0438 \u0432\u0435\u0440\u0441\u0438\u044f\u043c\u0438 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439 \u0438 \u0432\u0430\u043b\u0438\u0434\u0438\u0440\u043e\u0432\u0430\u0442\u044c \u0438\u0445 \u0441\u043e\u0433\u043b\u0430\u0441\u043d\u043e \u0437\u0430\u0434\u0430\u043d\u043d\u043e\u0439 \u0441\u0445\u0435\u043c\u044b.<\/p>\n<p>SR \u0445\u0440\u0430\u043d\u0438\u0442 \u0432\u00a0\u0441\u0435\u0431\u0435 \u043d\u0435\u00a0\u0442\u043e\u043b\u044c\u043a\u043e \u0442\u0435\u043a\u0443\u0449\u0443\u044e \u0441\u0445\u0435\u043c\u0443, \u043d\u043e\u00a0\u0438 \u0432\u0441\u044e \u0438\u0441\u0442\u043e\u0440\u0438\u044e \u0438\u0437\u043c\u0435\u043d\u0435\u043d\u0438\u0439, \u0440\u0430\u0431\u043e\u0442\u0430\u0435\u0442 \u0441\u00a0\u0444\u043e\u0440\u043c\u0430\u0442\u0430\u043c\u0438 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439 <a href=\"https:\/\/avro.apache.org\/\"><u>Avro<\/u><\/a>, <a href=\"https:\/\/json-schema.org\/\"><u>Json Schema<\/u><\/a> \u0438\u043b\u0438 <a href=\"https:\/\/developers.google.com\/protocol-buffers\/\"><u>Protocol buffers<\/u><\/a>, \u0430\u00a0\u0442\u0430\u043a\u0436\u0435 \u0441\u043b\u0435\u0434\u0438\u0442 \u0437\u0430\u00a0\u043e\u0431\u0440\u0430\u0442\u043d\u043e\u0439 \u0441\u043e\u0432\u043c\u0435\u0441\u0442\u0438\u043c\u043e\u0441\u0442\u044c\u044e \u043f\u0435\u0440\u0435\u0434\u0430\u0432\u0430\u0435\u043c\u044b\u0445 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439.<\/p>\n<p>SR \u0438\u043c\u0435\u0435\u0442 \u0441\u0432\u043e\u0439 RESTfull \u0438\u043d\u0442\u0435\u0440\u0444\u0435\u0439\u0441, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u043f\u0440\u0435\u0434\u043e\u0441\u0442\u0430\u0432\u043b\u044f\u0435\u0442 \u0434\u043e\u0441\u0442\u0443\u043f \u043a\u043e \u0432\u0441\u0435\u043c \u0434\u0435\u0439\u0441\u0442\u0432\u0438\u044f\u043c \u043d\u0430\u0434 \u0441\u0445\u0435\u043c\u0430\u043c\u0438 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439 (\u0441\u043e\u0437\u0434\u0430\u043d\u0438\u0435, \u0447\u0442\u0435\u043d\u0438\u0435, \u0443\u0434\u0430\u043b\u0435\u043d\u0438\u0435 \u0438 \u0442\u0434).<\/p>\n<h2>\u041a\u0430\u043a \u0440\u0430\u0431\u043e\u0442\u0430\u0435\u0442 SR?<\/h2>\n<p>\u041d\u0430\u00a0\u043f\u0440\u0438\u043c\u0435\u0440\u0435 \u0441\u0432\u044f\u0437\u043a\u0438 Kafka + Schema Registry + Protobuf, \u0440\u0430\u0441\u0441\u043c\u043e\u0442\u0440\u0438\u043c \u0432\u00a0\u0443\u043f\u0440\u043e\u0449\u0435\u043d\u043d\u043e\u0439 \u0441\u0445\u0435\u043c\u0435 \u043a\u0430\u043a\u00a0\u0440\u0430\u0431\u043e\u0442\u0430\u0435\u0442 SR (\u0441 \u043e\u0441\u0442\u0430\u043b\u044c\u043d\u044b\u043c\u0438 \u0444\u043e\u0440\u043c\u0430\u0442\u0430\u043c\u0438 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439 \u0432\u0441\u0435 \u043f\u043e\u0445\u043e\u0436\u0435, \u043d\u043e\u00a0\u0435\u0441\u0442\u044c \u0441\u0432\u043e\u0438 \u043d\u044e\u0430\u043d\u0441\u044b):<\/p>\n<ol>\n<li>\n<p>\u0412\u00a0\u0440\u0435\u043f\u043e\u0437\u0438\u0442\u043e\u0440\u0438\u0438 \u043f\u0440\u043e\u0434\u044e\u0441\u0435\u0440\u0430 Kafka \u0441\u043e\u0437\u0434\u0430\u0435\u0442\u0441\u044f, \u0441\u043e\u0445\u0440\u0430\u043d\u044f\u0435\u0442\u0441\u044f \u0438 \u043a\u043e\u043c\u043f\u0438\u043b\u0438\u0440\u0443\u0435\u0442\u0441\u044f \u043d\u0430\u00a0\u043d\u0443\u0436\u043d\u044b\u0439 \u044f\u0437\u044b\u043a \u0432\u00a0\u043e\u0431\u044a\u0435\u043a\u0442\u2011\u0441\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u0443 DTO \u0441\u0445\u0435\u043c\u0430 Protobuf.proto;<\/p>\n<\/li>\n<li>\n<p>\u041f\u0440\u0438\u00a0\u043e\u0442\u043f\u0440\u0430\u0432\u043a\u0435 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f, \u0435\u0441\u043b\u0438 \u0441\u0445\u0435\u043c\u0430 \u0435\u0449\u0435 \u043d\u0435\u00a0\u0431\u044b\u043b\u0430 \u0437\u0430\u0440\u0435\u0433\u0438\u0441\u0442\u0440\u0438\u0440\u043e\u0432\u0430\u043d\u0430 \u0432\u00a0SR, \u043a\u043b\u0438\u0435\u043d\u0442 SR \u0440\u0435\u0433\u0438\u0441\u0442\u0440\u0438\u0440\u0443\u0435\u0442 \u0435\u0435 \u0438 \u0434\u0430\u0435\u0442 \u0435\u0439 id \u0432\u0435\u0440\u0441\u0438\u0438. \u0415\u0441\u043b\u0438 \u0441\u0445\u0435\u043c\u0430 \u0443\u0436\u0435\u00a0\u0431\u044b\u043b\u0430 \u0437\u0430\u0440\u0435\u0433\u0438\u0441\u0442\u0440\u0438\u0440\u043e\u0432\u0430\u043d\u0430, \u0442\u043e \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u0435\u0442\u0441\u044f \u0441\u0443\u0449\u0435\u0441\u0442\u0432\u0443\u044e\u0449\u0438\u0439 id;<\/p>\n<\/li>\n<li>\n<p>\u0421\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u043e\u043f\u0440\u0435\u0434\u0435\u043b\u0435\u043d\u043d\u044b\u043c \u043e\u0431\u0440\u0430\u0437\u043e\u043c, \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u044f id \u0441\u0445\u0435\u043c\u044b, \u0441\u0435\u0440\u0438\u0430\u043b\u0438\u0437\u0443\u0435\u0442\u0441\u044f \u0438 \u043e\u0442\u043f\u0440\u0430\u0432\u043b\u044f\u0435\u0442\u0441\u044f \u0432\u00a0\u0431\u0440\u043e\u043a\u0435\u0440 Kafka;<\/p>\n<\/li>\n<li>\n<p>\u0420\u0435\u043f\u043e\u0437\u0438\u0442\u043e\u0440\u0438\u0439 \u043a\u043e\u043d\u0441\u044c\u044e\u043c\u0435\u0440\u0430 \u043d\u0435\u00a0\u0445\u0440\u0430\u043d\u0438\u0442 \u0432\u00a0\u0441\u0435\u0431\u0435 \u0438\u0441\u0445\u043e\u0434\u043d\u0443\u044e \u0441\u0445\u0435\u043c\u0443 Protobuf.proto, \u0430\u00a0\u0438\u043c\u0435\u0435\u0442 \u0442\u043e\u043b\u044c\u043a\u043e \u0441\u043a\u043e\u043c\u043f\u0438\u043b\u0438\u0440\u043e\u0432\u0430\u043d\u043d\u0443\u044e \u043d\u0430\u00a0\u043d\u0443\u0436\u043d\u044b\u0439 \u044f\u0437\u044b\u043a \u043e\u0431\u044a\u0435\u043a\u0442\u2011\u0441\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u0443 DTO;<\/p>\n<\/li>\n<li>\n<p>\u041a\u043e\u043d\u0441\u044c\u044e\u043c\u0435\u0440 \u043f\u043e\u043b\u0443\u0447\u0430\u0435\u0442 \u0441\u0435\u0440\u0438\u0430\u043b\u0438\u0437\u043e\u0432\u0430\u043d\u043d\u043e\u0435 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u0438\u0437\u00a0Kafka. \u0417\u0430\u0442\u0435\u043c \u043f\u043e\u00a0id \u0432\u0435\u0440\u0441\u0438\u0438 \u0441\u0445\u0435\u043c\u044b \u043f\u043e\u043b\u0443\u0447\u0430\u0435\u0442 \u0441\u0445\u0435\u043c\u0443 \u0438\u0437\u00a0SR \u0438 \u0434\u0435\u0441\u0435\u0440\u0438\u0430\u043b\u0438\u0437\u0443\u0435\u0442 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u0432\u00a0DTO.<\/p>\n<\/li>\n<\/ol>\n<h2>\u041f\u0438\u0448\u0435\u043c \u043f\u0440\u0438\u043c\u0435\u0440\u044b \u043d\u0430 Go<\/h2>\n<p>\u042f \u043d\u0435\u00a0\u0431\u0443\u0434\u0443 \u0440\u0430\u0441\u0441\u043a\u0430\u0437\u044b\u0432\u0430\u0442\u044c, \u043a\u0430\u043a\u00a0\u043f\u043e\u0434\u043d\u0438\u043c\u0430\u0442\u044c \u0438 \u043d\u0430\u0441\u0442\u0440\u0430\u0438\u0432\u0430\u0442\u044c \u0441\u0432\u044f\u0437\u043a\u0443 Kafka + Schema Registry. \u0414\u043b\u044f\u00a0\u043b\u043e\u043a\u0430\u043b\u044c\u043d\u043e\u0433\u043e \u0442\u0435\u0441\u0442\u0438\u0440\u043e\u0432\u0430\u043d\u0438\u044f \u0432\u044b \u043c\u043e\u0436\u0435\u0442\u0435 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u044c \u0443\u0436\u0435 \u0433\u043e\u0442\u043e\u0432\u044b\u0439 <a href=\"https:\/\/github.com\/confluentinc\/schema-registry-workshop\/blob\/master\/docker-compose.yml\"><u>docker\u2011compose<\/u><\/a> \u0444\u0430\u0439\u043b \u0438 \u0437\u0430\u043f\u0443\u0441\u0442\u0438\u0442\u044c \u0441\u0438\u0441\u0442\u0435\u043c\u0443 \u0443\u00a0\u0441\u0435\u0431\u044f \u0432\u00a0\u0434\u043e\u043a\u0435\u0440\u0435.<\/p>\n<p>\u0414\u043b\u044f\u00a0\u0440\u0430\u0431\u043e\u0442\u044b \u043d\u0430\u043c \u043f\u043e\u043d\u0430\u0434\u043e\u0431\u0438\u0442\u0441\u044f \u0431\u0440\u043e\u043a\u0435\u0440 Kafka \u0438 \u0441\u0435\u0440\u0432\u0435\u0440 Schema Registry \u0441\u00a0\u0438\u0437\u0432\u0435\u0441\u0442\u043d\u044b\u043c\u0438 \u043d\u0430\u043c \u0430\u0434\u0440\u0435\u0441\u0430\u043c\u0438, \u043a\u043e\u0442\u043e\u0440\u044b\u0435 \u043e\u0431\u043e\u0437\u043d\u0430\u0447\u0438\u043c \u043a\u0430\u043a <code>kafkaURL<\/code> \u0438 <code>srURL<\/code> \u0441\u043e\u043e\u0442\u0432\u0435\u0442\u0441\u0442\u0432\u0435\u043d\u043d\u043e.<\/p>\n<p>\u0414\u043b\u044f\u00a0\u0440\u0430\u0431\u043e\u0442\u044b \u0441\u00a0SR \u043d\u0430\u00a0\u044f\u0437\u044b\u043a\u0435 Go\u00a0\u0431\u044b\u043b\u043e \u043d\u0435\u0441\u043a\u043e\u043b\u044c\u043a\u043e \u0432\u0430\u0440\u0438\u0430\u043d\u0442\u043e\u0432: <\/p>\n<ul>\n<li>\n<p>\u041d\u0430\u043f\u0438\u0441\u0430\u0442\u044c \u043a\u043b\u0438\u0435\u043d\u0442 SR \u0441\u0430\u043c\u043e\u0441\u0442\u043e\u044f\u0442\u0435\u043b\u044c\u043d\u043e, \u0443\u0447\u0438\u0442\u044b\u0432\u0430\u044f \u0432\u0441\u0435 \u043d\u044e\u0430\u043d\u0441\u044b \u0432\u0437\u0430\u0438\u043c\u043e\u0434\u0435\u0439\u0441\u0442\u0432\u0438\u044f;<\/p>\n<\/li>\n<li>\n<p>\u0418\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u044c \u043d\u0430\u0442\u0438\u0432\u043d\u044b\u0439 \u043a\u043b\u0438\u0435\u043d\u0442 \u043e\u0442 <a href=\"https:\/\/www.confluent.io\/\"><u>Confluent<\/u><\/a>, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u043d\u0430\u0437\u044b\u0432\u0430\u0435\u0442\u0441\u044f <a href=\"https:\/\/github.com\/confluentinc\/confluent-kafka-go\"><u>confluent\u2011kafka\u2011go<\/u><\/a>.<\/p>\n<\/li>\n<\/ul>\n<p>\u041d\u0430\u0442\u0438\u0432\u043d\u044b\u0439 \u043a\u043b\u0438\u0435\u043d\u0442 \u043e\u0442\u00a0Confluent \u0435\u0441\u0442\u044c \u043d\u0435\u00a0\u0434\u043b\u044f\u00a0\u0432\u0441\u0435\u0445 \u044f\u0437\u044b\u043a\u043e\u0432, \u0430\u00a0\u0442\u043e\u043b\u044c\u043a\u043e \u0434\u043b\u044f <a href=\"https:\/\/docs.confluent.io\/5.4.3\/clients\/index.html#ak-clients\"><u>C\/C++, Python, Golang, Java,.NET<\/u><\/a>.<\/p>\n<p>\u041f\u043e\u044d\u0442\u043e\u043c\u0443, \u0442\u0430\u043a \u043a\u0430\u043a\u00a0\u043c\u043d\u0435 \u043f\u043e\u0432\u0435\u0437\u043b\u043e, \u044f \u0440\u0435\u0448\u0438\u043b\u0430 \u043f\u043e\u0439\u0442\u0438 \u0431\u043e\u043b\u0435\u0435 \u043f\u0440\u043e\u0441\u0442\u044b\u043c \u043f\u0443\u0442\u0435\u043c \u0438 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u044c \u0433\u043e\u0442\u043e\u0432\u044b\u0439 \u043a\u043b\u0438\u0435\u043d\u0442, \u0442\u0435\u043c \u0431\u043e\u043b\u0435\u0435 \u0447\u0442\u043e\u00a0\u0434\u043b\u044f\u00a0\u043d\u0435\u0433\u043e \u0441\u0443\u0449\u0435\u0441\u0442\u0432\u0443\u0435\u0442 \u0434\u043e\u0441\u0442\u0430\u0442\u043e\u0447\u043d\u043e \u043f\u043e\u0434\u0440\u043e\u0431\u043d\u0430\u044f \u0434\u043e\u043a\u0443\u043c\u0435\u043d\u0442\u0430\u0446\u0438\u044f \u0438 \u043d\u0435\u0441\u043a\u043e\u043b\u044c\u043a\u043e \u0440\u0430\u0431\u043e\u0447\u0438\u0445 \u043f\u0440\u0438\u043c\u0435\u0440\u043e\u0432.<\/p>\n<h3>\u0428\u0430\u0433 1: \u043f\u0440\u043e\u0434\u044e\u0441\u0435\u0440<\/h3>\n<p>\u041d\u0430\u043f\u0438\u0448\u0435\u043c SR \u043f\u0440\u043e\u0434\u044e\u0441\u0435\u0440 SRProducer, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u043f\u043e\u0437\u0432\u043e\u043b\u0438\u0442 \u0440\u0435\u0433\u0438\u0441\u0442\u0440\u0438\u0440\u043e\u0432\u0430\u0442\u044c \u0441\u0445\u0435\u043c\u0443 \u0432\u00a0SR \u0434\u043b\u044f\u00a0\u0444\u043e\u0440\u043c\u0430\u0442\u0430 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439 Protobuf \u0438 \u043e\u0442\u043f\u0440\u0430\u0432\u043b\u044f\u0442\u044c \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f \u0432\u00a0Kafka.<\/p>\n<p>\u041f\u043e\u043b\u043d\u044b\u0439 \u043a\u043e\u0434 SR \u043f\u0440\u043e\u0434\u044e\u0441\u0435\u0440\u0430 \u043c\u043e\u0436\u043d\u043e \u043f\u043e\u0441\u043c\u043e\u0442\u0440\u0435\u0442\u044c <a href=\"https:\/\/github.com\/PakshNina\/sr\/blob\/main\/internal\/kafka\/producer.go\"><u>\u0437\u0434\u0435\u0441\u044c<\/u><\/a>.<\/p>\n<pre><code class=\"go\">\/\/ SRProducer \u0438\u043d\u0442\u0435\u0440\u0444\u0435\u0439\u0441, \u0440\u0435\u0430\u043b\u0438\u0437\u0443\u044e\u0449\u0438\u0439 \u043c\u0435\u0442\u043e\u0434\u044b \u043f\u0440\u043e\u0434\u044e\u0441\u0435\u0440\u0430 SR type SRProducer interface {   ProduceMessage(msg proto.Message, topic string) (int64, error)   Close() }  type srProducer struct {   producer   *kafka.Producer   serializer serde.Serializer }  \/\/ NewProducer \u0432\u043e\u0437\u0432\u0440\u0430\u0449\u0430\u0435\u0442 \u043f\u0440\u043e\u0434\u044e\u0441\u0435\u0440 SR \u0434\u043b\u044f \u0440\u0430\u0431\u043e\u0442\u044b \u0441 kafka \u0438 schema registry func NewProducer(kafkaURL, srURL string) (SRProducer, error) {   p, err := kafka.NewProducer(&amp;kafka.ConfigMap{\"bootstrap.servers\": kafkaURL})   if err != nil {      return nil, err   }   c, err := schemaregistry.NewClient(schemaregistry.NewConfig(srURL))   if err != nil {      return nil, err   }   s, err := protobuf.NewSerializer(c, serde.ValueSerde, protobuf.NewSerializerConfig())   if err != nil {      return nil, err   }   return &amp;srProducer{      producer:   p,      serializer: s,   }, nil }<\/code><\/pre>\n<p>NewProducer \u0432\u043e\u0437\u0432\u0440\u0430\u0449\u0430\u0435\u0442 SR \u043f\u0440\u043e\u0434\u044e\u0441\u0435\u0440, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u0440\u0435\u0430\u043b\u0438\u0437\u0443\u0435\u0442 \u0438\u043d\u0442\u0435\u0440\u0444\u0435\u0439\u0441 SRProducer.<\/p>\n<p>\u0414\u043b\u044f\u00a0\u0440\u0430\u0431\u043e\u0442\u044b \u043d\u0430\u0448\u0435\u0433\u043e \u043f\u0440\u043e\u0434\u044e\u0441\u0435\u0440\u0430 \u043d\u0435\u043e\u0431\u0445\u043e\u0434\u0438\u043c\u043e \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0438\u0442\u044c:<\/p>\n<ul>\n<li>\n<p>\u043f\u0440\u043e\u0434\u044e\u0441\u0435\u0440 Kafka <code>kafka.NewProducer(...)<\/code>;<\/p>\n<\/li>\n<\/ul>\n<ul>\n<li>\n<p>\u043a\u043b\u0438\u0435\u043d\u0442 REST API Schema Regisftry <code>schemaregistry.NewClient(...)<\/code>;<\/p>\n<\/li>\n<li>\n<p>\u0441\u0435\u0440\u0438\u0430\u043b\u0438\u0437\u0430\u0442\u043e\u0440 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439 \u0432\u00a0\u0444\u043e\u0440\u043c\u0430\u0442 Protobuf <code>protobuf.NewSerializer(...)<\/code>.<\/p>\n<\/li>\n<\/ul>\n<p>\u041e\u0431\u0440\u0430\u0442\u0438\u0442\u0435 \u0432\u043d\u0438\u043c\u0430\u043d\u0438\u0435, \u0447\u0442\u043e\u00a0\u043f\u0440\u0438\u00a0\u0441\u043e\u0437\u0434\u0430\u043d\u0438\u0438 \u0441\u0435\u0440\u0438\u0430\u043b\u0438\u0437\u0430\u0442\u043e\u0440\u0430 <code>protobuf.NewSerializer(...)<\/code> \u043f\u0435\u0440\u0435\u0434\u0430\u0435\u0442\u0441\u044f \u043f\u0430\u0440\u0430\u043c\u0435\u0442\u0440 <code>serde.ValueSerde<\/code>. \u0417\u0430\u043f\u043e\u043c\u043d\u0438\u043c \u044d\u0442\u043e \u043c\u0435\u0441\u0442\u043e \u0438 \u0447\u0443\u0442\u044c \u0434\u0430\u043b\u044c\u0448\u0435 \u043e\u0431\u0441\u0443\u0434\u0438\u043c, \u0447\u0442\u043e\u00a0\u043e\u043d \u0437\u043d\u0430\u0447\u0438\u0442.<\/p>\n<p>SR \u043f\u0440\u043e\u0434\u044e\u0441\u0435\u0440 <code>SRProducer<\/code> \u0440\u0435\u0430\u043b\u0438\u0437\u0443\u0435\u0442 \u0434\u0432\u0430 \u043c\u0435\u0442\u043e\u0434\u0430: <code>ProduceMessage<\/code>, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u0440\u0435\u0433\u0438\u0441\u0442\u0440\u0438\u0440\u0443\u0435\u0442 \u0441\u0445\u0435\u043c\u0443 \u0438 \u043e\u0442\u043f\u0440\u0430\u0432\u043b\u044f\u0435\u0442 \u0434\u0430\u043d\u043d\u044b\u0435 \u0432\u00a0Kafka, \u0430\u00a0\u0442\u0430\u043a\u0436\u0435 <code>Close<\/code> \u0434\u043b\u044f\u00a0\u0437\u0430\u043a\u0440\u044b\u0442\u0438\u044f \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u0439.<\/p>\n<pre><code class=\"go\">const (   nullOffset = -1 )  \/\/ ProduceMessage \u043e\u0442\u043f\u0440\u0430\u0432\u043b\u044f\u0435\u0442 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 proto.Message \u0432 \u043e\u043f\u0440\u0435\u0434\u0435\u043b\u0435\u043d\u043d\u044b\u0439 \u0442\u043e\u043f\u0438\u043a func (p *srProducer) ProduceMessage(msg proto.Message, topic string) (int64, error) {   kafkaChan := make(chan kafka.Event)   defer close(kafkaChan)   payload, err := p.serializer.Serialize(topic, msg)   if err != nil {      return nullOffset, err   }   if err = p.producer.Produce(&amp;kafka.Message{      TopicPartition: kafka.TopicPartition{Topic: &amp;topic},      Value:          payload,   }, kafkaChan); err != nil {      return nullOffset, err   }   e := &lt;-kafkaChan   switch ev := e.(type) {   case *kafka.Message:      return int64(ev.TopicPartition.Offset), nil   case kafka.Error:      return nullOffset, err   }   return nullOffset, nil }  \/\/ Close \u0437\u0430\u043a\u0440\u044b\u0432\u0430\u0435\u0442 \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u0435 \u0441 schema registry \u0438 kafka func (p *srProducer) Close() {   p.serializer.Close()   p.producer.Close() }<\/code><\/pre>\n<p>\u041c\u0435\u0442\u043e\u0434 <code>ProduceMessage<\/code> \u043e\u0442\u043f\u0440\u0430\u0432\u043b\u044f\u0435\u0442 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f \u0442\u0438\u043f\u0430 <code>proto.Message<\/code> \u0432\u00a0Kafka. \u041f\u0435\u0440\u0435\u0434 \u043e\u0442\u043f\u0440\u0430\u0432\u043a\u043e\u0439 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u0441\u0435\u0440\u0438\u0430\u043b\u0438\u0437\u0443\u0435\u0442\u0441\u044f.<\/p>\n<p>\u0417\u0430\u0442\u0435\u043c, \u0441\u00a0\u043f\u043e\u043c\u043e\u0449\u044c\u044e \u043c\u0435\u0442\u043e\u0434\u0430 <code>p.producer.Produce<\/code> \u043f\u0440\u043e\u0434\u044e\u0441\u0435\u0440\u0430 Kafka \u043c\u044b \u043e\u0442\u043f\u0440\u0430\u0432\u043b\u044f\u0435\u043c \u0441\u0435\u0440\u0438\u0430\u043b\u0438\u0437\u043e\u0432\u0430\u043d\u043d\u043e\u0435 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u0432\u00a0\u0431\u0440\u043e\u043a\u0435\u0440. \u041e\u0442\u0447\u0435\u0442 \u043e\u0431\u00a0\u043e\u0442\u043f\u0440\u0430\u0432\u043a\u0435 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f \u043f\u0440\u0438\u0445\u043e\u0434\u0438\u0442 \u0432\u00a0\u043a\u0430\u043d\u0430\u043b <code>kafka.Event<\/code>.<\/p>\n<p>\u0414\u043b\u044f\u00a0\u0438\u043d\u0444\u043e\u0440\u043c\u0430\u0442\u0438\u0432\u043d\u043e\u0441\u0442\u0438 \u043d\u0430\u0448 \u043c\u0435\u0442\u043e\u0434 ProduceMessage \u0431\u0443\u0434\u0435\u0442 \u0432\u043e\u0437\u0432\u0440\u0430\u0449\u0430\u0442\u044c <code>offset<\/code> \u0437\u0430\u043f\u0438\u0441\u0430\u043d\u043d\u043e\u0433\u043e \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f \u0438 \u043e\u0448\u0438\u0431\u043a\u0443, \u0435\u0441\u043b\u0438 \u043e\u043d\u0430 \u0432\u043e\u0437\u043d\u0438\u043a\u043b\u0430.<\/p>\n<p>\u0412\u00a0\u043a\u0430\u0447\u0435\u0441\u0442\u0432\u0435 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f Protobuf \u0431\u0443\u0434\u0435\u043c \u043f\u0435\u0440\u0435\u0434\u0430\u0432\u0430\u0442\u044c \u0441\u043b\u0435\u0434\u0443\u044e\u0449\u0435\u0435 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 <a href=\"https:\/\/github.com\/PakshNina\/sr\/blob\/main\/proto\/test.v1.proto\"><u>test.v1.proto<\/u><\/a> \u0441\u043e \u0441\u0445\u0435\u043c\u043e\u0439:<\/p>\n<pre><code class=\"yaml\">syntax = \"proto3\"; option go_package = \".\/pkg\/test.v1\"; package test.v1;  message TestMessage {  int32 Value = 1; }<\/code><\/pre>\n<p>\u0412\u0430\u0436\u043d\u043e \u0443\u043a\u0430\u0437\u0430\u0442\u044c \u0434\u0438\u0440\u0435\u043a\u0442\u0438\u0432\u0443 package \u0432.proto \u0444\u0430\u0439\u043b\u0435, \u043e\u0441\u043e\u0431\u0435\u043d\u043d\u043e \u0432\u00a0\u0440\u0430\u0437\u0440\u0435\u0437\u0435 \u0440\u0430\u0431\u043e\u0442\u044b \u0441\u00a0\u043d\u0435\u0441\u043a\u043e\u043b\u044c\u043a\u0438\u043c\u0438 \u0432\u0435\u0440\u0441\u0438\u044f\u043c\u0438 \u043e\u0434\u043d\u043e\u0433\u043e \u043a\u043e\u043d\u0442\u0440\u0430\u043a\u0442\u0430. Go \u043d\u0435\u00a0c\u043a\u043e\u043c\u043f\u0438\u043b\u0438\u0440\u0443\u0435\u0442 \u043a\u043e\u0434, \u0435\u0441\u043b\u0438 \u0432\u00a0\u043e\u0434\u043d\u043e\u043c \u043f\u0430\u043a\u0435\u0442\u0435 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u0435\u0442\u0441\u044f \u0434\u0432\u0435 \u0432\u0435\u0440\u0441\u0438\u0438 \u043a\u043e\u043d\u0442\u0440\u0430\u043a\u0442\u043e\u0432 \u0441\u00a0\u043e\u0434\u0438\u043d\u0430\u043a\u043e\u0432\u044b\u043c\u0438 \u0438\u043b\u0438\u00a0\u043e\u0442\u0441\u0443\u0442\u0441\u0442\u0432\u0443\u044e\u0449\u0438\u043c package.<\/p>\n<p>\u0421\u0433\u0435\u043d\u0435\u0440\u0438\u0440\u043e\u0432\u0430\u0442\u044c \u0438\u0437.proto \u0444\u0430\u0439\u043b\u0430 go \u043a\u043e\u0434 \u043c\u043e\u0436\u043d\u043e \u0441\u00a0\u043f\u043e\u043c\u043e\u0449\u044c\u044e \u043a\u043e\u043c\u0430\u043d\u0434\u044b (\u043e\u043d \u0431\u0443\u0434\u0435\u0442 \u0441\u0433\u0435\u043d\u0435\u0440\u0438\u0440\u043e\u0432\u0430\u043d \u0432\u00a0\u043f\u0430\u043f\u043a\u0443 pkg\/test.v1):<\/p>\n<pre><code class=\"powershell\">protoc --go_out=. proto\/test.v1.proto<\/code><\/pre>\n<p>\u0414\u043b\u044f\u00a0\u0433\u0435\u043d\u0435\u0440\u0430\u0446\u0438\u0438 \u043a\u043e\u0434\u0430 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u0435\u0442\u0441\u044f \u0443\u0442\u0438\u043b\u0438\u0442\u0430 <a href=\"https:\/\/grpc.io\/docs\/protoc-installation\/\"><u>protoc<\/u><\/a>.<\/p>\n<p>\u0422\u0430\u043a\u0436\u0435 \u043e\u0431\u0440\u0430\u0442\u0438\u0442\u0435 \u0432\u043d\u0438\u043c\u0430\u043d\u0438\u0435, \u0447\u0442\u043e\u00a0\u0434\u043b\u044f\u00a0\u0433\u0435\u043d\u0435\u0440\u0430\u0446\u0438\u0438 \u043a\u043e\u0434\u0430 \u0432\u00a0go \u043d\u0435\u043e\u0431\u0445\u043e\u0434\u0438\u043c\u0430 \u043e\u043f\u0446\u0438\u044f go_package, \u043a\u043e\u0442\u043e\u0440\u0430\u044f \u043e\u043f\u0440\u0435\u0434\u0435\u043b\u044f\u0435\u0442 \u043f\u0443\u0442\u044c \u0438\u043c\u043f\u043e\u0440\u0442\u0430 \u043f\u0430\u043a\u0435\u0442\u0430 c \u0441\u0433\u0435\u043d\u0435\u0440\u0438\u0440\u043e\u0432\u0430\u043d\u043d\u044b\u043c \u043a\u043e\u0434\u043e\u043c.<\/p>\n<p>\u0415\u0441\u043b\u0438 \u0432\u00a0\u043a\u043e\u043d\u0442\u0440\u0430\u043a\u0442\u0435 \u043e\u043d\u0430 \u043e\u0442\u0441\u0443\u0442\u0441\u0442\u0432\u0443\u0435\u0442, \u043c\u043e\u0436\u043d\u043e \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u044c M \u0444\u043b\u0430\u0433 \u0434\u043b\u044f\u00a0\u0443\u043a\u0430\u0437\u0430\u043d\u0438\u044f \u043f\u0443\u0442\u0438 \u0438\u043c\u043f\u043e\u0440\u0442\u0430 \u043f\u0430\u043a\u0435\u0442\u0430 (\u0441\u0433\u0435\u043d\u0435\u0440\u0438\u0440\u043e\u0432\u0430\u043d\u043d\u044b\u0439 \u043a\u043e\u0434 \u0431\u0443\u0434\u0435\u0442 \u0442\u0430\u043a\u0436\u0435 \u043b\u0435\u0436\u0430\u0442\u044c \u0432\u00a0pkg\/test.v1):<\/p>\n<pre><code class=\"powershell\">protoc --go_out=. --proto_path=proto --go_opt=Mtest.v1.proto=.\/pkg\/test.v1 proto\/test.v1.proto<\/code><\/pre>\n<p>\u0421\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 TestMessage \u0431\u0443\u0434\u0435\u043c \u043e\u0442\u043f\u0440\u0430\u0432\u043b\u044f\u0442\u044c \u0432 \u0442\u043e\u043f\u0438\u043a \u2018topic.v1\u2019 Kafka. \u041f\u043e\u043b\u043d\u044b\u0439 \u043a\u043e\u0434 \u043f\u0440\u0438\u043c\u0435\u0440\u0430 \u0434\u043b\u044f \u0444\u0443\u043d\u043a\u0446\u0438\u0438 main <a href=\"https:\/\/github.com\/PakshNina\/sr\/blob\/main\/cmd\/producer\/main.go\"><u>\u0437\u0434\u0435\u0441\u044c<\/u><\/a>:<\/p>\n<pre><code class=\"go\">const (   topic = \"topic.v1\" )  func main() {   kafkaURL := os.Getenv(\"KAFKA_URL\")   schemaRegistryURL := os.Getenv(\"SCHEMA_REGISTRY_URL\")   producer, err := kafka.NewProducer(kafkaURL, schemaRegistryURL)   defer producer.Close()    if err != nil {      log.Fatalf(\"error with producer: %v\", err)   }   testMSG := test.TestMessage{Value: 42}   offset, err := producer.ProduceMessage(&amp;testMSG, topic)   if err != nil {      log.Fatalf(\"error with produce message: %v\", err)   }   fmt.Println(offset) }<\/code><\/pre>\n<p>\u0415\u0441\u043b\u0438 \u043c\u044b \u0437\u0430\u043f\u0443\u0441\u0442\u0438\u043c \u043a\u043e\u0434, \u043d\u0435\u00a0\u0437\u0430\u0431\u044b\u0432 \u0443\u043a\u0430\u0437\u0430\u0442\u044c \u0432\u00a0\u043f\u0435\u0440\u0435\u043c\u0435\u043d\u043d\u044b\u0445 \u043e\u043a\u0440\u0443\u0436\u0435\u043d\u0438\u044f <code>KafkaURL<\/code> \u0438 <code>SchemaRegistryURL<\/code> \u043f\u043e\u0434\u00a0\u0438\u043c\u0435\u043d\u0430\u043c\u0438 <code>KAFKA_URL<\/code> \u0438 <code>SCHEMA_REGISTRY_URL<\/code>, \u0442\u043e \u043c\u044b \u043f\u043e\u043b\u0443\u0447\u0438\u043c \u0438\u0437\u00a0Kafka \u0441\u0434\u0432\u0438\u0433 offset \u0434\u043b\u044f\u00a0\u043d\u0430\u0448\u0435\u0433\u043e \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u0440\u0430\u0432\u0435\u043d 0. \u0412\u0441\u0435 \u0440\u0430\u0431\u043e\u0442\u0430\u0435\u0442!<\/p>\n<p>\u041d\u043e\u00a0\u043f\u043e\u0433\u043e\u0434\u0438\u0442\u0435, \u0447\u0442\u043e\u00a0\u0437\u043d\u0430\u0447\u0438\u0442 \u0432\u0441\u0435 \u0440\u0430\u0431\u043e\u0442\u0430\u0435\u0442? \u0417\u0430\u0433\u0440\u0443\u0437\u0438\u043b\u0430\u0441\u044c\u00a0\u043b\u0438 \u0441\u0445\u0435\u043c\u0430? \u0427\u0442\u043e\u00a0\u0432\u043e\u043e\u0431\u0449\u0435 \u043f\u0440\u043e\u0438\u0437\u043e\u0448\u043b\u043e?<\/p>\n<p>\u0415\u0441\u043b\u0438 \u0432\u044b \u043f\u043e\u043c\u043d\u0438\u0442\u0435, SR \u043f\u0440\u0435\u0434\u043e\u0441\u0442\u0430\u0432\u043b\u044f\u0435\u0442 REST API \u0434\u043b\u044f\u00a0\u0440\u0430\u0431\u043e\u0442\u044b \u0441\u043e \u0441\u0445\u0435\u043c\u0430\u043c\u0438, \u043f\u043e\u044d\u0442\u043e\u043c\u0443, \u043c\u044b \u043c\u043e\u0436\u0435\u043c \u0441\u0434\u0435\u043b\u0430\u0442\u044c \u0437\u0430\u043f\u0440\u043e\u0441 \u043d\u0430\u00a0\u043f\u043e\u043b\u0443\u0447\u0435\u043d\u0438\u0435 \u0432\u0441\u0435\u0445 \u0441\u0443\u0449\u0435\u0441\u0442\u0432\u0443\u044e\u0449\u0438\u0445 \u0441\u0445\u0435\u043c (<code>{{schema-registry-url}}<\/code> \u00a0\u2014 \u0430\u0434\u0440\u0435\u0441 \u043d\u0430\u0448\u0435\u0433\u043e \u0441\u0435\u0440\u0432\u0435\u0440\u0430 SR):<\/p>\n<pre><code class=\"yaml\">GET {{schema-registry-url}}\/schemas\/<\/code><\/pre>\n<p>\u0412 \u043e\u0442\u0432\u0435\u0442 \u043c\u044b \u043f\u043e\u043b\u0443\u0447\u0438\u043c:<\/p>\n<pre><code class=\"yaml\">[   {        \"subject\": \"topic.v1-value\",        \"version\": 1,        \"id\": 1,        \"schemaType\": \"PROTOBUF\",        \"schema\": \"syntax = \\\"proto3\\\";\\npackage test.v1;\\n\\noption go_package = \\\".\/pkg\/test.v1\\\";\\n\\nmessage TestMessage {\\n  int32 Value = 1;\\n}\\n\"    } ]<\/code><\/pre>\n<p>\u0412\u00a0\u043f\u043e\u043b\u0435 schema \u043c\u044b \u0432\u0438\u0434\u0438\u043c \u0438\u0441\u0445\u043e\u0434\u043d\u044b\u0439 \u0444\u0430\u0439\u043b.proto \u0432\u00a0\u0442\u0435\u043a\u0441\u0442\u043e\u0432\u043e\u043c \u0432\u0438\u0434\u0435.<\/p>\n<p>\u041a\u0430\u043a\u00a0\u0441\u0445\u0435\u043c\u0430 \u043f\u043e\u043f\u0430\u043b\u0430 \u0432\u00a0SR, \u0435\u0441\u043b\u0438 \u043c\u044b \u043d\u0438\u0447\u0435\u0433\u043e \u0432\u0440\u0443\u0447\u043d\u0443\u044e \u043d\u0435\u00a0\u0441\u043e\u0437\u0434\u0430\u0432\u0430\u043b\u0438 \u0438 \u043d\u0435\u00a0\u0432\u044b\u0437\u044b\u0432\u0430\u043b\u0438 \u043d\u0438\u043a\u0430\u043a\u0438\u0445 POST?<\/p>\n<p>\u0414\u0435\u043b\u043e \u0432\u00a0\u0442\u043e\u043c, \u043f\u043e\u00a0\u0443\u043c\u043e\u043b\u0447\u0430\u043d\u0438\u044e \u0443\u00a0\u0441\u0435\u0440\u0438\u0430\u043b\u0438\u0437\u0430\u0442\u043e\u0440\u0430 SR \u0432\u043a\u043b\u044e\u0447\u0435\u043d\u0430 \u043e\u043f\u0446\u0438\u044f <code>AutoRegisterSchemas<\/code>, \u043a\u043e\u0442\u043e\u0440\u0430\u044f \u0430\u0432\u0442\u043e\u043c\u0430\u0442\u0438\u0447\u0435\u0441\u043a\u0438 \u0440\u0435\u0433\u0438\u0441\u0442\u0440\u0438\u0440\u0443\u0435\u0442 \u0441\u0445\u0435\u043c\u044b \u043f\u0440\u0438\u00a0\u0441\u0435\u0440\u0438\u0430\u043b\u0438\u0437\u0430\u0446\u0438\u0438 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439 (<a href=\"https:\/\/github.com\/confluentinc\/confluent-kafka-go\/blob\/master\/schemaregistry\/serde\/config.go#L31\">\u0438\u0441\u0445\u043e\u0434\u043d\u0438\u043a<\/a>).<\/p>\n<figure class=\"full-width\"><img loading=\"lazy\" decoding=\"async\" src=\"https:\/\/habrastorage.org\/r\/w1560\/getpro\/habr\/upload_files\/483\/6a6\/a82\/4836a6a82de9c2a0ffd60b0f21eb59d8.png\" alt=\"\u0420\u0438\u0441 2. \u041a\u043e\u043d\u0444\u0438\u0433 \u0441\u0435\u0440\u0438\u0430\u043b\u0438\u0437\u0430\u0442\u043e\u0440\u0430 SR \u043f\u043e \u0443\u043c\u043e\u043b\u0447\u0430\u043d\u0438\u044e \u0432 schemaregistry\/serde\/config.go\" title=\"\u0420\u0438\u0441 2. \u041a\u043e\u043d\u0444\u0438\u0433 \u0441\u0435\u0440\u0438\u0430\u043b\u0438\u0437\u0430\u0442\u043e\u0440\u0430 SR \u043f\u043e \u0443\u043c\u043e\u043b\u0447\u0430\u043d\u0438\u044e \u0432 schemaregistry\/serde\/config.go\" width=\"1274\" height=\"486\" data-src=\"https:\/\/habrastorage.org\/getpro\/habr\/upload_files\/483\/6a6\/a82\/4836a6a82de9c2a0ffd60b0f21eb59d8.png\"\/><figcaption>\u0420\u0438\u0441 2. \u041a\u043e\u043d\u0444\u0438\u0433 \u0441\u0435\u0440\u0438\u0430\u043b\u0438\u0437\u0430\u0442\u043e\u0440\u0430 SR \u043f\u043e \u0443\u043c\u043e\u043b\u0447\u0430\u043d\u0438\u044e \u0432 schemaregistry\/serde\/config.go<\/figcaption><\/figure>\n<p>\u0421\u0445\u0435\u043c\u0430 \u0430\u0432\u0442\u043e\u043c\u0430\u0442\u0438\u0447\u0435\u0441\u043a\u0438 \u0440\u0435\u0433\u0438\u0441\u0442\u0440\u0438\u0440\u0443\u0435\u0442\u0441\u044f \u043f\u0440\u0438\u00a0\u0432\u044b\u0437\u043e\u0432\u0435 \u043c\u0435\u0442\u043e\u0434\u0430 <code>p.serializer.Serialize<\/code>, \u0438 \u0435\u0441\u043b\u0438 \u043e\u043d\u0430 \u043d\u0435\u00a0\u0441\u0443\u0449\u0435\u0441\u0442\u0432\u043e\u0432\u0430\u043b\u0430, \u0435\u0439 \u043f\u0440\u0438\u0441\u0432\u0430\u0438\u0432\u0430\u0435\u0442\u0441\u044f \u043d\u043e\u0432\u044b\u0439 id.<\/p>\n<p>\u0422\u0430\u043a \u043a\u0430\u043a\u00a0\u043c\u044b \u043e\u0442\u043f\u0440\u0430\u0432\u0438\u043b\u0438 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u0432\u00a0\u043f\u0435\u0440\u0432\u044b\u0439 \u0440\u0430\u0437, \u043d\u0430\u0448\u0430 \u0441\u0445\u0435\u043c\u0430 \u0430\u0432\u0442\u043e\u043c\u0430\u0442\u0438\u0447\u0435\u0441\u043a\u0438 \u0437\u0430\u0440\u0435\u0433\u0438\u0441\u0442\u0440\u0438\u0440\u043e\u0432\u0430\u043b\u0430\u0441\u044c \u0441\u00a0id = 1, version = 1\u00a0\u0438 \u0442\u0438\u043f\u043e\u043c PROTOBUF.<\/p>\n<p>\u0415\u0434\u0438\u043d\u0441\u0442\u0432\u0435\u043d\u043d\u043e\u0435, \u0447\u0442\u043e\u00a0\u0441\u0440\u0430\u0437\u0443 \u0432\u044b\u0437\u044b\u0432\u0430\u0435\u0442 \u0432\u043e\u043f\u0440\u043e\u0441\u00a0\u2014 \u044d\u0442\u043e \u043f\u043e\u043b\u0435 subject, \u0432\u00a0\u043a\u043e\u0442\u043e\u0440\u043e\u043c \u0437\u043d\u0430\u0447\u0435\u043d\u0438\u0435 <code>topic.v1-value<\/code>, \u043d\u0435\u0441\u043c\u043e\u0442\u0440\u044f \u043d\u0430\u00a0\u0442\u043e, \u0447\u0442\u043e\u00a0\u0432\u00a0\u0431\u0440\u043e\u043a\u0435\u0440\u0435 Kafka \u043c\u044b \u043d\u0430\u0437\u0432\u0430\u043b\u0438 \u0442\u043e\u043f\u0438\u043a <code>topic.v1<\/code>. \u041e\u0442\u043a\u0443\u0434\u0430 \u043f\u043e\u044f\u0432\u0438\u043b\u0441\u044f \u043f\u043e\u0441\u0442\u0444\u0438\u043a\u0441 <code>-value<\/code>?<\/p>\n<p>SR \u0440\u0435\u0433\u0438\u0441\u0442\u0440\u0438\u0440\u0443\u0435\u0442 \u0441\u0445\u0435\u043c\u0443 \u0432\u00a0\u0441\u0432\u043e\u0435\u043c \u0440\u0435\u0435\u0441\u0442\u0440\u0435 \u0432\u00a0\u043f\u0440\u043e\u0441\u0442\u0440\u0430\u043d\u0441\u0442\u0432\u0435 \u0438\u043c\u0435\u043d <code>subject<\/code>. \u0412\u00a0\u0440\u0430\u043c\u043a\u0430\u0445 \u043e\u0434\u043d\u043e\u0433\u043e \u043f\u0440\u043e\u0441\u0442\u0440\u0430\u043d\u0441\u0442\u0432\u0430 \u0438\u043c\u0435\u043d \u043f\u0440\u043e\u0438\u0437\u0432\u043e\u0434\u0438\u0442\u0441\u044f \u043f\u0440\u043e\u0432\u0435\u0440\u043a\u0430 \u043d\u0430\u00a0\u0441\u043e\u0432\u043c\u0435\u0441\u0442\u0438\u043c\u043e\u0441\u0442\u044c \u0441\u0445\u0435\u043c. \u0412\u0441\u0435 \u0432\u0435\u0440\u0441\u0438\u0438 \u0441\u0445\u0435\u043c\u044b \u043f\u0440\u0438\u0432\u044f\u0437\u0430\u043d\u044b \u043a\u00a0\u043e\u0434\u043d\u043e\u043c\u0443 \u043f\u0440\u043e\u0441\u0442\u0440\u0430\u043d\u0441\u0442\u0432\u0443 \u0438\u043c\u0435\u043d. \u041a\u043e\u0433\u0434\u0430 \u0441\u0445\u0435\u043c\u0430 \u043c\u0435\u043d\u044f\u0435\u0442\u0441\u044f, \u043e\u043d\u0430 \u0432\u0441\u0435 \u0442\u0430\u043a\u00a0\u0436\u0435 \u043f\u0440\u0438\u0432\u044f\u0437\u0430\u043d\u0430 \u043a\u00a0\u0438\u0441\u0445\u043e\u0434\u043d\u043e\u043c\u0443 \u043f\u0440\u043e\u0441\u0442\u0440\u0430\u043d\u0441\u0442\u0432\u0443 \u0438\u043c\u0435\u043d, \u043d\u043e\u00a0\u0443\u00a0\u043d\u0435\u0435 \u043c\u0435\u043d\u044f\u0435\u0442\u0441\u044f id \u0438 \u0432\u0435\u0440\u0441\u0438\u044f \u0441\u0445\u0435\u043c\u044b.<\/p>\n<p>\u0412\u00a0SR \u0437\u0430\u0434\u0430\u043d\u043e \u043d\u0435\u0441\u043a\u043e\u043b\u044c\u043a\u043e \u0441\u0442\u0440\u0430\u0442\u0435\u0433\u0438\u0439 \u0434\u043b\u044f\u00a0\u043e\u043f\u0440\u0435\u0434\u0435\u043b\u0435\u043d\u0438\u044f \u043f\u0440\u043e\u0441\u0442\u0440\u0430\u043d\u0441\u0442\u0432\u0430 \u0438\u043c\u0435\u043d. \u041f\u043e\u00a0\u0443\u043c\u043e\u043b\u0447\u0430\u043d\u0438\u044e \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u0435\u0442\u0441\u044f <code>TopicRecordNameStrategy<\/code>. \u0417\u0434\u0435\u0441\u044c \u0432\u00a0\u043a\u0430\u0447\u0435\u0441\u0442\u0432\u0435 \u0431\u0430\u0437\u044b \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u0435\u0442\u0441\u044f \u0438\u043c\u044f \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u0435\u043c\u043e\u0433\u043e \u0442\u043e\u043f\u0438\u043a\u0430 \u0432\u00a0Kafka.<\/p>\n<p>\u0410\u00a0\u043f\u043e\u0441\u0442\u0444\u0438\u043a\u0441 \u043e\u043f\u0440\u0435\u0434\u0435\u043b\u044f\u0435\u0442\u0441\u044f \u043f\u0430\u0440\u0430\u043c\u0435\u0442\u0440\u043e\u043c, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u043c\u044b \u043f\u0435\u0440\u0435\u0434\u0430\u0432\u0430\u043b\u0438 \u0432\u00a0\u0441\u0435\u0440\u0438\u0430\u043b\u0438\u0437\u0430\u0442\u043e\u0440, \u0438 \u0432\u00a0\u043d\u0430\u0448\u0435\u043c \u0441\u043b\u0443\u0447\u0430\u0435 \u044d\u0442\u043e <code>serde.ValueSerde<\/code>. \u0418\u043c\u0435\u043d\u043d\u043e \u043e\u043d \u043e\u043f\u0440\u0435\u0434\u0435\u043b\u044f\u0435\u0442 \u043a\u0430\u043a\u043e\u0439 \u043f\u043e\u0441\u0442\u0444\u0438\u043a\u0441 \u0431\u0443\u0434\u0435\u0442 \u043d\u0430\u00a0\u043a\u043e\u043d\u0446\u0435 \u0442\u043e\u043f\u0438\u043a\u0430: <code>serde.ValueSerde<\/code> \u0434\u043b\u044f <code>-value<\/code> (\u0435\u0441\u0442\u044c \u0442\u0430\u043a\u0436\u0435 \u043f\u0430\u0440\u0430\u043c\u0435\u0442\u0440 <code>serde.KeySerde<\/code>, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u0441\u043e\u043e\u0442\u0432\u0435\u0442\u0441\u0442\u0432\u0443\u0435\u0442 \u043f\u043e\u0441\u0442\u0444\u0438\u043a\u0441\u0443 <code>-key<\/code>)<\/p>\n<p>\u0421\u0442\u0440\u0430\u0442\u0435\u0433\u0438\u044f \u043d\u0430\u0437\u0432\u0430\u043d\u0438\u044f \u043f\u0440\u043e\u0441\u0442\u0440\u0430\u043d\u0441\u0442\u0432\u0430 \u0438\u043c\u0435\u043d \u043c\u043e\u0436\u0435\u0442\u00a0\u0431\u044b\u0442\u044c \u043e\u0442\u043b\u0438\u0447\u043d\u0430 \u043e\u0442 <code>TopicRecordNameStrategy<\/code>. \u041d\u0430\u043f\u0440\u0438\u043c\u0435\u0440, \u0435\u0449\u0435 \u0441\u0443\u0449\u0435\u0441\u0442\u0432\u0443\u0435\u0442 <a href=\"https:\/\/docs.confluent.io\/platform\/current\/schema-registry\/serdes-develop\/index.html#subject-name-strategy\"><u>RecordNameStrategy<\/u><\/a>, \u043a\u043e\u0433\u0434\u0430 \u043f\u0440\u043e\u0441\u0442\u0440\u0430\u043d\u0441\u0442\u0432\u043e \u0438\u043c\u0435\u043d \u0441\u0445\u0435\u043c\u044b \u043e\u043f\u0440\u0435\u0434\u0435\u043b\u044f\u0435\u0442\u0441\u044f \u043d\u0430\u0437\u0432\u0430\u043d\u0438\u0435\u043c \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f \u0432\u00a0\u0441\u0445\u0435\u043c\u0435 Protobuf. \u0422\u0430\u043a\u043e\u0439 \u043c\u0435\u0445\u0430\u043d\u0438\u0437\u043c \u043d\u0443\u0436\u0435\u043d, \u0435\u0441\u043b\u0438 \u0432\u00a0\u0440\u0430\u043c\u043a\u0430\u0445 \u043e\u0434\u043d\u043e\u0433\u043e \u0442\u043e\u043f\u0438\u043a\u0430 Kafka \u043f\u0435\u0440\u0435\u0434\u0430\u0435\u0442\u0441\u044f \u043d\u0435\u0441\u043a\u043e\u043b\u044c\u043a\u043e \u0440\u0430\u0437\u043d\u044b\u0445 \u0442\u0438\u043f\u043e\u0432 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439 Protobuf, \u0438 \u0434\u043b\u044f\u00a0\u043d\u0438\u0445 \u0442\u0430\u043a\u0436\u0435 \u043d\u0443\u0436\u043d\u043e \u0432\u0430\u043b\u0438\u0434\u0438\u0440\u043e\u0432\u0430\u0442\u044c \u0441\u0445\u0435\u043c\u044b.<\/p>\n<p>\u041d\u043e\u00a0\u0438\u043c\u0435\u0439\u0442\u0435 \u0432\u00a0\u0432\u0438\u0434\u0443, \u0447\u0442\u043e\u00a0\u0434\u043b\u044f\u00a0\u043a\u043b\u0438\u0435\u043d\u0442\u0430 Go \u0432\u00a0confluent\u2011kafka\u2011go \u0440\u0435\u0430\u043b\u0438\u0437\u043e\u0432\u0430\u043d\u0430 \u0442\u043e\u043b\u044c\u043a\u043e TopicRecordNameStrategy.<\/p>\n<p>\u0412\u00a0\u043f\u043e\u043b\u0435 \u00abschema\u00bb \u043c\u044b \u0432\u0438\u0434\u0438\u043c \u043d\u0430\u0448 \u0438\u0441\u0445\u043e\u0434\u043d\u044b\u0439.proto \u0444\u0430\u0439\u043b: <code>syntax = \"proto3\";\\npackage test.v1;\\n\\noption go_package = \".\/pkg\/test.v1\";\\n\\nmessage TestMessage {\\n  int32 Value = 1;\\n}\\n<\/code><\/p>\n<p>\u041a\u0430\u043a\u00a0SR \u0443\u0437\u043d\u0430\u0435\u0442, \u043e\u0442\u043a\u0443\u0434\u0430 \u0435\u0433\u043e \u0431\u0440\u0430\u0442\u044c? \u0427\u0442\u043e\u00a0\u0431\u0443\u0434\u0435\u0442 \u0435\u0441\u043b\u0438 \u043c\u044b \u0432\u00a0\u043a\u043e\u0434\u0435 \u043f\u0435\u0440\u0435\u043d\u0435\u0441\u0435\u043c \u044d\u0442\u043e\u0442 \u0444\u0430\u0439\u043b \u0432\u00a0\u0434\u0440\u0443\u0433\u043e\u0435 \u043c\u0435\u0441\u0442\u043e \u0438\u043b\u0438\u00a0\u0443\u0434\u0430\u043b\u0438\u043c? \u041f\u0440\u043e\u0434\u044e\u0441\u0435\u0440 \u043d\u0435\u00a0\u0441\u043c\u043e\u0436\u0435\u0442 \u043e\u0442\u043f\u0440\u0430\u0432\u0438\u0442\u044c \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435?<\/p>\n<p>\u041e\u043a\u0430\u0437\u044b\u0432\u0430\u0435\u0442\u0441\u044f, \u0434\u043b\u044f\u00a0\u0442\u043e\u0433\u043e, \u0447\u0442\u043e\u0431\u044b \u043e\u0442\u043f\u0440\u0430\u0432\u0438\u0442\u044c \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435, \u0441\u0435\u0440\u0438\u0430\u043b\u0438\u0437\u0430\u0442\u043e\u0440\u0443 \u043d\u0435\u00a0\u043d\u0443\u0436\u0435\u043d \u0438\u0441\u0445\u043e\u0434\u043d\u044b\u0439 \u0444\u0430\u0439\u043b.proto. \u0412\u0441\u0435 \u0434\u0430\u043d\u043d\u044b\u0435 \u043e\u00a0\u0441\u0445\u0435\u043c\u0435 Protobuf \u043e\u043d \u0432\u043e\u0441\u0441\u0442\u0430\u043d\u0430\u0432\u043b\u0438\u0432\u0430\u0435\u0442 \u0438\u0437\u00a0proto.Message. \u0412\u0441\u044f \u043c\u0430\u0433\u0438\u044f \u043f\u0440\u043e\u0438\u0441\u0445\u043e\u0434\u0438\u0442 \u0432\u00a0\u043c\u0435\u0442\u043e\u0434\u0435 <a href=\"https:\/\/github.com\/confluentinc\/confluent-kafka-go\/blob\/b6a3254310f6d9707f283f0b53ef4d3e1ff48e3b\/schemaregistry\/serde\/protobuf\/protobuf.go#L194\"><u>toProtobufSchema<\/u><\/a>.<\/p>\n<figure class=\"full-width\"><img loading=\"lazy\" decoding=\"async\" src=\"https:\/\/habrastorage.org\/r\/w1560\/getpro\/habr\/upload_files\/13e\/e5f\/622\/13ee5f622fdd4ecd7b50cacc1a4e4538.png\" alt=\"\u0420\u0438\u0441 3. \u0413\u0435\u043d\u0435\u0440\u0430\u0446\u0438\u044f \u0438\u0441\u0445\u043e\u0434\u043d\u043e\u0439 \u0441\u0445\u0435\u043c\u044b .proto \u0438\u0437 proto.Message\" title=\"\u0420\u0438\u0441 3. \u0413\u0435\u043d\u0435\u0440\u0430\u0446\u0438\u044f \u0438\u0441\u0445\u043e\u0434\u043d\u043e\u0439 \u0441\u0445\u0435\u043c\u044b .proto \u0438\u0437 proto.Message\" width=\"1702\" height=\"408\" data-src=\"https:\/\/habrastorage.org\/getpro\/habr\/upload_files\/13e\/e5f\/622\/13ee5f622fdd4ecd7b50cacc1a4e4538.png\"\/><figcaption>\u0420\u0438\u0441 3. \u0413\u0435\u043d\u0435\u0440\u0430\u0446\u0438\u044f \u0438\u0441\u0445\u043e\u0434\u043d\u043e\u0439 \u0441\u0445\u0435\u043c\u044b .proto \u0438\u0437 proto.Message<\/figcaption><\/figure>\n<h3>\u0428\u0430\u0433 2: \u041a\u043e\u043d\u0441\u044c\u044e\u043c\u0435\u0440 SR<\/h3>\n<p>\u041d\u0430\u00a0\u043f\u0440\u0435\u0434\u044b\u0434\u0443\u0449\u0435\u043c \u0448\u0430\u0433\u0435 \u043c\u044b \u0441\u00a0\u043f\u043e\u043c\u043e\u0449\u044c\u044e SR \u043f\u0440\u043e\u0434\u044e\u0441\u0435\u0440\u0430 \u043e\u0442\u043f\u0440\u0430\u0432\u0438\u043b\u0438 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u0432\u00a0\u0431\u0440\u043e\u043a\u0435\u0440 Kafka. \u0421\u0435\u0439\u0447\u0430\u0441 \u043d\u0430\u043f\u0438\u0448\u0435\u043c SR \u043a\u043e\u043d\u0441\u044c\u044e\u043c\u0435\u0440, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u043f\u043e\u043b\u0443\u0447\u0438\u0442 \u044d\u0442\u043e \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u0438\u0437\u00a0Kafka.<\/p>\n<p>NewConsumer \u0432\u043e\u0437\u0432\u0440\u0430\u0449\u0430\u0435\u0442 \u043d\u043e\u0432\u044b\u0439 SR \u043a\u043e\u043d\u0441\u044c\u044e\u043c\u0435\u0440, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u0440\u0435\u0430\u043b\u0438\u0437\u0443\u0435\u0442 \u0438\u043d\u0442\u0435\u0440\u0444\u0435\u0439\u0441 SRConsumer. \u0414\u043b\u044f\u00a0\u0440\u0430\u0431\u043e\u0442\u044b \u043d\u0430\u043c \u043d\u0435\u043e\u0431\u0445\u043e\u0434\u0438\u043c\u043e \u0441\u043e\u0437\u0434\u0430\u0442\u044c:<\/p>\n<ul>\n<li>\n<p>\u043a\u043e\u043d\u0441\u044c\u044e\u043c\u0435\u0440 Kafka <code>kafka.NewConsumer(...)<\/code><\/p>\n<\/li>\n<li>\n<p>\u043a\u043b\u0438\u0435\u043d\u0442 SR <code>schemaregistry.NewClient(...)<\/code> <\/p>\n<\/li>\n<li>\n<p>\u0434\u0435\u0441\u0435\u0440\u0438\u0430\u043b\u0438\u0437\u0430\u0442\u043e\u0440 Protobuf <code>protobuf.NewDeserializer(...)<\/code><\/p>\n<\/li>\n<\/ul>\n<p>\u041f\u043e\u043b\u043d\u044b\u0439 \u043a\u043e\u0434 SR \u043a\u043e\u043d\u0441\u044c\u044e\u043c\u0435\u0440\u0430 <a href=\"https:\/\/github.com\/PakshNina\/sr\/blob\/main\/internal\/kafka\/consumer.go\"><u>\u0437\u0434\u0435\u0441\u044c<\/u><\/a>.<\/p>\n<pre><code class=\"go\">const (   consumerGroupID       = \"test-consumer\"   defaultSessionTimeout = 6000   noTimeout             = -1 )  \/\/ SRConsumer \u0438\u043d\u0442\u0435\u0440\u0444\u0435\u0439\u0441, \u0440\u0435\u0430\u043b\u0438\u0437\u0443\u044e\u0449\u0438\u0439 \u043c\u0435\u0442\u043e\u0434\u044b SR \u043a\u043e\u043d\u0441\u044c\u044e\u043c\u0435\u0440\u0430 type SRConsumer interface {   Run(messageType protoreflect.MessageType, topic string) error   Close() }   type srConsumer struct {   consumer     *kafka.Consumer   deserializer *protobuf.Deserializer }  \/\/ NewConsumer \u0432\u043e\u0437\u0432\u0440\u0430\u0449\u0430\u0435\u0442 \u043d\u043e\u0432\u044b\u0439 SR \u043a\u043e\u043d\u0441\u044c\u044e\u043c\u0435\u0440 \u0434\u043b\u044f \u0440\u0430\u0431\u043e\u0442\u044b \u0441 Kafka \u0438 SR func NewConsumer(kafkaURL, srURL string) (SRConsumer, error) {   c, err := kafka.NewConsumer(&amp;kafka.ConfigMap{      \"bootstrap.servers\":  kafkaURL,      \"group.id\":           consumerGroupID,      \"session.timeout.ms\": defaultSessionTimeout,      \"enable.auto.commit\": false,   })   if err != nil {      return nil, err   }    sr, err := schemaregistry.NewClient(schemaregistry.NewConfig(srURL))   if err != nil {      return nil, err   }    d, err := protobuf.NewDeserializer(sr, serde.ValueSerde, protobuf.NewDeserializerConfig())   if err != nil {      return nil, err   }   return &amp;srConsumer{      consumer:     c,      deserializer: d,   }, nil }<\/code><\/pre>\n<p>\u0418\u043d\u0442\u0435\u0440\u0444\u0435\u0439\u0441 SRConsumer \u0441\u043e\u0434\u0435\u0440\u0436\u0438\u0442 \u043c\u0435\u0442\u043e\u0434\u044b:<\/p>\n<ul>\n<li>\n<p><code>Run<\/code>\u00a0\u2014 \u0434\u043b\u044f\u00a0\u0437\u0430\u043f\u0443\u0441\u043a\u0430 \u043a\u043e\u043d\u0441\u044c\u044e\u043c\u0435\u0440\u0430 SR, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u043f\u043e\u0437\u0432\u043e\u043b\u044f\u0435\u0442 \u0447\u0438\u0442\u0430\u0442\u044c \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f \u0438\u0437\u00a0Kafka, \u0441\u043e\u043f\u043e\u0441\u0442\u0430\u0432\u043b\u044f\u0442\u044c \u0438\u0445 \u0441\u043e \u0441\u0445\u0435\u043c\u043e\u0439 \u0438\u0437\u00a0SR \u0438 \u0434\u0435\u0441\u0435\u0440\u0438\u0430\u043b\u0438\u0437\u043e\u0432\u0430\u0442\u044c \u0432\u00a0\u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 proto.Message;<\/p>\n<\/li>\n<li>\n<p><code>Close<\/code>\u00a0\u2014 \u0434\u043b\u044f\u00a0\u0437\u0430\u0432\u0435\u0440\u0448\u0435\u043d\u0438\u044f \u0440\u0430\u0431\u043e\u0442\u044b \u043a\u043b\u0438\u0435\u043d\u0442\u043e\u0432.<\/p>\n<\/li>\n<\/ul>\n<p>\u041c\u0435\u0442\u043e\u0434 <code>Run<\/code> \u0437\u0430\u043f\u0443\u0441\u043a\u0430\u0435\u0442 SR \u043a\u043e\u043d\u0441\u044c\u044e\u043c\u0435\u0440. \u041f\u0435\u0440\u0435\u0434 \u0447\u0442\u0435\u043d\u0438\u0435\u043c \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439 \u0438\u0437\u00a0Kafka \u043f\u0440\u043e\u0438\u0441\u0445\u043e\u0434\u0438\u0442 \u0434\u0432\u0430 \u0432\u0430\u0436\u043d\u044b\u0445 \u0441\u043e\u0431\u044b\u0442\u0438\u044f: <\/p>\n<ul>\n<li>\n<p><code>c.consumer.SubscribeTopics(...)<\/code> \u043f\u043e\u0434\u043f\u0438\u0441\u044b\u0432\u0430\u0435\u0442 \u043a\u043e\u043d\u0441\u044c\u044e\u043c\u0435\u0440 Kafka \u043d\u0430\u00a0\u043d\u0443\u0436\u043d\u044b\u0439 \u0442\u043e\u043f\u0438\u043a.<\/p>\n<\/li>\n<li>\n<p><code>c.deserializer.ProtoRegistry.RegisterMessage(...)<\/code> \u0440\u0435\u0433\u0438\u0441\u0442\u0440\u0438\u0440\u0443\u0435\u0442 \u0434\u0435\u0441\u043a\u0440\u0438\u043f\u0442\u043e\u0440 \u0442\u0438\u043f\u0430 <code>protoreflect.MessageType<\/code> \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f, \u0432\u00a0\u043a\u043e\u0442\u043e\u0440\u043e\u0435 \u043c\u044b \u0431\u0443\u0434\u0435\u043c \u0434\u0435\u0441\u0435\u0440\u0438\u0430\u043b\u0438\u0437\u043e\u0432\u0430\u0442\u044c \u0431\u0430\u0439\u0442\u044b \u0438\u0437\u00a0Kafka.<\/p>\n<\/li>\n<\/ul>\n<pre><code class=\"go\">\/\/ Run \u0437\u0430\u043f\u0443\u0441\u043a\u0430\u0435\u0442 SR \u043a\u043e\u043d\u0441\u044c\u044e\u043c\u0435\u0440 func (c *srConsumer) Run(messageType protoreflect.MessageType, topic string) error {   if err := c.consumer.SubscribeTopics([]string{topic}, nil); err != nil {      return err   }   if err := c.deserializer.ProtoRegistry.RegisterMessage(messageType); err != nil {      return err   }   for {      kafkaMsg, err := c.consumer.ReadMessage(noTimeout)      if err != nil {         return err      }      msg, err := c.deserializer.Deserialize(topic, kafkaMsg.Value)      if err != nil {         return err      }      c.handleMessage(msg, int64(kafkaMsg.TopicPartition.Offset))      if _, err = c.consumer.CommitMessage(kafkaMsg); err != nil {         return err      }   } }  func (c *srConsumer) handleMessage(message interface{}, offset int64) {   fmt.Printf(\"message %v with offset %d\\n\", message, offset) }<\/code><\/pre>\n<p>\u041e\u0440\u0433\u0430\u043d\u0438\u0437\u043e\u0432\u0430\u0442\u044c \u0440\u0430\u0431\u043e\u0442\u0443 \u043a\u043e\u043d\u0441\u044c\u044e\u043c\u0435\u0440\u0430 SR \u043c\u043e\u0436\u043d\u043e \u0441 \u043f\u043e\u043c\u043e\u0449\u044c\u044e \u043f\u0443\u043b\u0430 \u0432\u043e\u0440\u043a\u0435\u0440\u043e\u0432 (worker pool), \u043d\u043e \u0432 \u043d\u0430\u0448\u0435\u043c \u0441\u043b\u0443\u0447\u0430\u0435 \u043d\u0430\u043f\u0438\u0448\u0435\u043c \u0431\u043e\u043b\u0435\u0435 \u043f\u0440\u043e\u0441\u0442\u043e\u0439 \u043f\u0440\u0438\u043c\u0435\u0440, \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u044f \u043c\u0435\u0442\u043e\u0434 <code>Poll()<\/code> (<code>ReadMessage<\/code> \u2014 \u043e\u0431\u043e\u043b\u043e\u0447\u043a\u0430 \u043d\u0430\u0434 \u0444\u0443\u043d\u043a\u0446\u0438\u0435\u0439 <code>Poll<\/code>), \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u043e\u043f\u0440\u0430\u0448\u0438\u0432\u0430\u0435\u0442 \u043e\u043f\u0440\u0435\u0434\u0435\u043b\u0435\u043d\u043d\u044b\u0439 \u0442\u043e\u043f\u0438\u043a \u0441 \u0437\u0430\u0434\u0430\u043d\u043d\u044b\u043c \u0442\u0430\u0439\u043c\u0430\u0443\u0442\u043e\u043c. \u0412 \u043d\u0430\u0448\u0435\u043c \u0441\u043b\u0443\u0447\u0430\u0435 \u0442\u0430\u0439\u043c\u0430\u0443\u0442 <code>noTimeout = -1<\/code>, \u0442\u043e \u0435\u0441\u0442\u044c \u0440\u0430\u0432\u0435\u043d \u0431\u0435\u0441\u043a\u043e\u043d\u0435\u0447\u043d\u043e\u0441\u0442\u0438.<\/p>\n<p>\u0412 \u043f\u043e\u043b\u0435 <code>msgKafka.Value<\/code> \u0445\u0440\u0430\u043d\u0438\u0442\u0441\u044f \u0441\u0435\u0440\u0438\u0430\u043b\u0438\u0437\u043e\u0432\u0430\u043d\u043d\u043e\u0435 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u0432 \u0432\u0438\u0434\u0435 \u043c\u0430\u0441\u0441\u0438\u0432\u0430 \u0431\u0430\u0439\u0442\u043e\u0432 []byte, \u043f\u043e\u043b\u0443\u0447\u0435\u043d\u043d\u043e\u0435 \u0438\u0437 Kafka.<\/p>\n<p>\u0414\u043b\u044f \u0442\u043e\u0433\u043e, \u0447\u0442\u043e\u0431\u044b \u044d\u0442\u043e \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u0434\u0435\u0441\u0435\u0440\u0438\u0430\u043b\u0438\u0437\u043e\u0432\u0430\u0442\u044c \u0432 \u043d\u0443\u0436\u043d\u0443\u044e \u0441\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u0443 DTO, \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u0435\u0442\u0441\u044f \u043c\u0435\u0442\u043e\u0434 \u0434\u0435\u0441\u0435\u0440\u0438\u0430\u043b\u0438\u0437\u0430\u0442\u043e\u0440\u0430 <code>c.deserializer.Deserialize(...)<\/code>.<\/p>\n<p>\u0414\u0435\u0441\u0435\u0440\u0438\u0430\u043b\u0438\u0437\u043e\u0432\u0430\u043d\u043d\u043e\u0435 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 msg \u043e\u0442\u043f\u0440\u0430\u0432\u043b\u044f\u0435\u0442\u0441\u044f \u0432 \u043e\u0431\u0440\u0430\u0431\u043e\u0442\u0447\u0438\u043a <code>c.handleMessage(...)<\/code>, \u0433\u0434\u0435 \u043e\u0431\u0440\u0430\u0431\u0430\u0442\u044b\u0432\u0430\u0435\u0442\u0441\u044f \u043d\u0443\u0436\u043d\u044b\u043c \u043d\u0430\u043c \u043e\u0431\u0440\u0430\u0437\u043e\u043c.<\/p>\n<p>\u041d\u0430\u043f\u0438\u0448\u0435\u043c \u043f\u0440\u043e\u0433\u0440\u0430\u043c\u043c\u0443 \u0434\u043b\u044f \u0432\u044b\u0437\u043e\u0432\u0430 SR \u043a\u043e\u043d\u0441\u044c\u044e\u043c\u0435\u0440\u0430 (\u043f\u043e\u043b\u043d\u044b\u0439 \u043a\u043e\u0434 <a href=\"https:\/\/github.com\/PakshNina\/sr\/blob\/main\/cmd\/consumer\/main.go\"><u>\u0437\u0434\u0435\u0441\u044c<\/u><\/a>).<\/p>\n<pre><code class=\"go\">const (   topic = \"topic.v1\" )  func main() {   kafkaURL := os.Getenv(\"KAFKA_URL\")   schemaRegistryURL := os.Getenv(\"SCHEMA_REGISTRY_URL\")   consumer, err := kafka.NewConsumer(kafkaURL, schemaRegistryURL)   defer consumer.Close()    if err != nil {      log.Fatal(err)   }   messageType := (&amp;test.TestMessage{}).ProtoReflect().Type()   if err := consumer.Run(messageType, topic); err != nil {      log.Fatal(err)   } }<\/code><\/pre>\n<p>\u0415\u0441\u043b\u0438 \u043c\u044b \u0437\u0430\u043f\u0443\u0441\u0442\u0438\u043c \u043d\u0430\u0448 \u043a\u043e\u043d\u0441\u044c\u044e\u043c\u0435\u0440, \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u0438\u0437 \u0442\u043e\u043f\u0438\u043a\u0430 \u0443\u0441\u043f\u0435\u0448\u043d\u043e \u0434\u0435\u0441\u0435\u0440\u0438\u0430\u043b\u0438\u0437\u0443\u0435\u0442\u0441\u044f:<\/p>\n<pre><code class=\"powershell\">message Value:42 with offset 0<\/code><\/pre>\n<p>\u0422\u0430\u043a\u0438\u043c \u043e\u0431\u0440\u0430\u0437\u043e\u043c, \u043c\u044b \u043f\u0440\u043e\u0447\u0438\u0442\u0430\u043b\u0438 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u0438\u0437 \u043d\u0443\u0436\u043d\u043e\u0433\u043e \u043d\u0430\u043c \u0442\u043e\u043f\u0438\u043a\u0430 \u0438 \u0434\u0435\u0441\u0435\u0440\u0438\u0430\u043b\u0438\u0437\u043e\u0432\u0430\u043b\u0438 \u0435\u0433\u043e \u0432 DTO.<\/p>\n<h3>\u0428\u0430\u0433 3: \u041e\u0431\u043d\u043e\u0432\u043b\u044f\u0435\u043c \u043a\u043e\u043d\u0442\u0440\u0430\u043a\u0442\u044b<\/h3>\n<p>\u041d\u0430\u0448\u0435 \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u0435 \u0440\u0430\u0441\u0442\u0435\u0442, \u0440\u0430\u0441\u0448\u0438\u0440\u044f\u0435\u0442\u0441\u044f \u0438 \u0442\u0440\u0435\u0431\u0443\u0435\u0442 \u0434\u043e\u0440\u0430\u0431\u043e\u0442\u043a\u0438 \u043a\u043e\u043d\u0442\u0440\u0430\u043a\u0442\u0430 \u043c\u0435\u0436\u0434\u0443 \u043a\u043e\u043d\u0441\u044c\u044e\u043c\u0435\u0440\u0430\u043c\u0438 \u0438 \u043f\u0440\u043e\u0434\u044e\u0441\u0435\u0440\u043e\u043c.<\/p>\n<p>\u041d\u0430\u043f\u0440\u0438\u043c\u0435\u0440, \u043c\u044b \u0445\u043e\u0442\u0438\u043c \u0434\u043e\u0431\u0430\u0432\u0438\u0442\u044c \u043d\u043e\u0432\u043e\u0435 \u043f\u043e\u043b\u0435 Message \u0432 \u043d\u0430\u0448 \u043a\u043e\u043d\u0442\u0440\u0430\u043a\u0442:<\/p>\n<pre><code class=\"yaml\">syntax = \"proto3\"; option go_package = \".\/pkg\/test.v1\"; package test.v1;  message TestMessage {  int32 Value = 1;  string Message = 2; }<\/code><\/pre>\n<p>\u0422\u0435\u043f\u0435\u0440\u044c \u043f\u0440\u043e\u0434\u044e\u0441\u0435\u0440 \u043e\u0442\u043f\u0440\u0430\u0432\u043b\u044f\u0435\u0442 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u0432 \u043d\u043e\u0432\u043e\u043c \u0444\u043e\u0440\u043c\u0430\u0442\u0435:<\/p>\n<pre><code class=\"go\">test.TestMessage{Value: 42, Message: \"test\"}<\/code><\/pre>\n<p>\u0415\u0441\u043b\u0438 \u043c\u044b \u0441\u0434\u0435\u043b\u0430\u0435\u043c \u0441\u043d\u043e\u0432\u0430 \u0437\u0430\u043f\u0440\u043e\u0441 \u043d\u0430 \u043f\u043e\u043b\u0443\u0447\u0435\u043d\u0438\u0435 \u0432\u0441\u0435\u0445 \u0441\u0445\u0435\u043c \u0432 SR, \u043c\u044b \u043f\u043e\u043b\u0443\u0447\u0438\u043c \u0434\u0432\u0435 \u0432\u0435\u0440\u0441\u0438\u0438 \u043d\u0430\u0448\u0438\u0445 \u0441\u0445\u0435\u043c, \u0441 id = 1 \u0438 \u043d\u043e\u0432\u0443\u044e \u0441 id = 2:<\/p>\n<pre><code class=\"yaml\">[   {        \"subject\": \"topic.v1-value\",        \"version\": 1,        \"id\": 1,        \"schemaType\": \"PROTOBUF\",        \"schema\": \"syntax = \\\"proto3\\\";\\npackage test.v1;\\n\\noption go_package = \\\".\/pkg.test.v1\\\";\\n\\nmessage TestMessage {\\n  int32 Value = 1;\\n}\\n\"    },    {        \"subject\": \"topic.v1-value\",        \"version\": 2,        \"id\": 2,        \"schemaType\": \"PROTOBUF\",        \"schema\": \"syntax = \\\"proto3\\\";\\npackage test.v1;\\n\\noption go_package = \\\".\/pkg\/test.v1\\\";\\n\\nmessage TestMessage {\\n  int32 Value = 1;\\n  string Message = 2;\\n}\\n\"    } ]<\/code><\/pre>\n<p>\u0415\u0441\u043b\u0438 \u043c\u044b \u0437\u0430\u043f\u0443\u0441\u0442\u0438\u043c \u043d\u0430\u0448 \u043a\u043e\u043d\u0441\u044c\u044e\u043c\u0435\u0440, \u043d\u0435 \u043e\u0431\u043d\u043e\u0432\u043b\u044f\u044f \u043f\u0440\u0435\u0434\u043e\u0441\u0442\u0430\u0432\u043b\u0435\u043d\u043d\u044b\u0439 DTO \u043d\u043e\u0432\u044b\u043c \u043f\u043e\u043b\u0435\u043c, \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u0438\u0437 \u0442\u043e\u043f\u0438\u043a\u0430 \u0441 \u043d\u043e\u0432\u044b\u043c \u043a\u043e\u043d\u0442\u0440\u0430\u043a\u0442\u043e\u043c \u0431\u0435\u0441\u043f\u0440\u0435\u043f\u044f\u0442\u0441\u0442\u0432\u0435\u043d\u043d\u043e \u0441\u0435\u0440\u0438\u0430\u043b\u0438\u0437\u0443\u0435\u0442\u0441\u044f \u0432 \u0441\u0442\u0430\u0440\u0443\u044e \u0432\u0435\u0440\u0441\u0438\u044e DTO. \u0422\u0430\u043a\u0438\u043c \u043e\u0431\u0440\u0430\u0437\u043e\u043c, \u0441\u043e\u0432\u043c\u0435\u0441\u0442\u0438\u043c\u043e\u0441\u0442\u044c \u043c\u0435\u0436\u0434\u0443 \u043f\u0440\u043e\u0434\u044e\u0441\u0435\u0440\u043e\u043c \u0438 \u043a\u043e\u043d\u0441\u044c\u044e\u043c\u0435\u0440\u043e\u043c \u043d\u0435 \u043d\u0430\u0440\u0443\u0448\u0438\u0442\u0441\u044f.<\/p>\n<p>\u041f\u043e\u043f\u0440\u043e\u0431\u0443\u0435\u043c \u0434\u043e\u0440\u0430\u0431\u043e\u0442\u0430\u0442\u044c \u043a\u043e\u043d\u0442\u0440\u0430\u043a\u0442 \u0441\u043b\u0435\u0434\u0443\u044e\u0449\u0438\u043c \u043e\u0431\u0440\u0430\u0437\u043e\u043c: \u0432\u043c\u0435\u0441\u0442\u043e \u0434\u043e\u0431\u0430\u0432\u043b\u0435\u043d\u0438\u044f \u043f\u043e\u043b\u044f \u0438\u0437\u043c\u0435\u043d\u0438\u043c \u0435\u0433\u043e \u0442\u0438\u043f. \u041f\u043e\u043b\u0435 <code>Value<\/code> \u0441\u0442\u0430\u043b\u043e \u0442\u0438\u043f\u043e\u043c <code>string<\/code>.<\/p>\n<pre><code class=\"yaml\">syntax = \"proto3\"; option go_package = \".\/pkg\/test.v1\"; package test.v1;  message TestMessage {  string Value = 1;  string Message = 2; }<\/code><\/pre>\n<p>\u041f\u0440\u043e\u0434\u044e\u0441\u0435\u0440 \u0431\u0443\u0434\u0435\u0442 \u043e\u0442\u043f\u0440\u0430\u0432\u043b\u044f\u0442\u044c \u0441\u043b\u0435\u0434\u0443\u044e\u0449\u0435\u0435 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435:<\/p>\n<pre><code class=\"go\">testMsg := test.TestMessage{Value: \"42\", Message: \"test\"}<\/code><\/pre>\n<p>\u0418 \u043f\u0440\u0438\u00a0 \u043f\u043e\u043f\u044b\u0442\u043a\u0435 \u043e\u0442\u043f\u0440\u0430\u0432\u0438\u0442\u044c \u0435\u0433\u043e \u0432 Kafka, \u043d\u0430\u0448 SR \u043a\u043e\u043d\u0441\u044c\u044e\u043c\u0435\u0440 \u0432\u0435\u0440\u043d\u0435\u0442 \u043e\u0448\u0438\u0431\u043a\u0443:<\/p>\n<pre><code class=\"powershell\">schema registry request failed error code: 409: Schema being registered is incompatible with an earlier schema for subject \"topic.v1-value\"<\/code><\/pre>\n<p>\u0414\u0430\u043d\u043d\u0430\u044f \u043e\u0448\u0438\u0431\u043a\u0430 \u043e\u0437\u043d\u0430\u0447\u0430\u0435\u0442, \u0447\u0442\u043e\u00a0\u043d\u043e\u0432\u0430\u044f \u0441\u0445\u0435\u043c\u0430 \u043d\u0435\u00a0\u043e\u0442\u0432\u0435\u0447\u0430\u0435\u0442 \u043f\u0440\u0430\u0432\u0438\u043b\u0430\u043c \u0441\u043e\u0432\u043c\u0435\u0441\u0442\u0438\u043c\u043e\u0441\u0442\u0438 \u0441\u00a0\u043f\u0440\u0435\u0434\u044b\u0434\u0443\u0449\u0438\u043c\u0438 \u0441\u0445\u0435\u043c\u0430\u043c\u0438 \u0438 \u043e\u043d\u0430 \u043b\u043e\u043c\u0430\u0435\u0442 \u0440\u0430\u0431\u043e\u0442\u0443 \u043a\u043e\u043d\u0441\u044c\u044e\u043c\u0435\u0440\u043e\u0432, \u043a\u043e\u0442\u043e\u0440\u044b\u0435 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u044e\u0442 \u043f\u0440\u0435\u0434\u044b\u0434\u0443\u0449\u0438\u0435 \u0432\u0435\u0440\u0441\u0438\u0438 \u0441\u0445\u0435\u043c.<\/p>\n<p>\u0423\u00a0SR \u0435\u0441\u0442\u044c \u0440\u0430\u0437\u043d\u044b\u0435 \u0443\u0440\u043e\u0432\u043d\u0438 \u0441\u043e\u0432\u043c\u0435\u0441\u0442\u0438\u043c\u043e\u0441\u0442\u0438. \u041f\u043e\u00a0\u0443\u043c\u043e\u043b\u0447\u0430\u043d\u0438\u044e \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u0435\u0442\u0441\u044f \u0443\u0440\u043e\u0432\u0435\u043d\u044c \u0441\u043e\u0432\u043c\u0435\u0441\u0442\u0438\u043c\u043e\u0441\u0442\u0438 BACKWARD, \u0442\u043e \u0435\u0441\u0442\u044c \u043e\u0431\u0440\u0430\u0442\u043d\u044b\u0439 \u0443\u0440\u043e\u0432\u0435\u043d\u044c \u0441\u043e\u0432\u043c\u0435\u0441\u0442\u0438\u043c\u043e\u0441\u0442\u0438.<\/p>\n<p>\u041d\u0430\u043f\u0440\u0438\u043c\u0435\u0440, \u0435\u0441\u043b\u0438 \u043c\u044b \u0434\u043e\u0431\u0430\u0432\u0438\u043b\u0438 \u043d\u043e\u0432\u043e\u0435 \u043f\u043e\u043b\u0435 \u0438\u043b\u0438\u00a0\u0443\u0434\u0430\u043b\u0438\u043b\u0438 \u043f\u0440\u0435\u0436\u043d\u0435\u0435 \u043f\u0440\u0438\u00a0\u0443\u0440\u043e\u0432\u043d\u0435 \u0441\u043e\u0432\u043c\u0435\u0441\u0442\u0438\u043c\u043e\u0441\u0442\u0438 BACKWARD \u0441\u0445\u0435\u043c\u0430 \u043f\u0440\u043e\u0439\u0434\u0435\u0442 \u0432\u0430\u043b\u0438\u0434\u0430\u0446\u0438\u044e.<\/p>\n<p>\u0410\u00a0\u0435\u0441\u043b\u0438, \u043d\u0430\u043f\u0440\u0438\u043c\u0435\u0440, \u0443\u00a0\u0441\u0443\u0449\u0435\u0441\u0442\u0432\u0443\u044e\u0449\u0435\u0433\u043e \u043f\u043e\u043b\u044f \u0432\u044b \u0438\u0437\u043c\u0435\u043d\u0438\u043b\u0438 \u0442\u0438\u043f \u0434\u0430\u043d\u043d\u044b\u0445, \u0442\u043e \u043e\u0431\u0440\u0430\u0442\u043d\u0430\u044f \u0441\u043e\u0432\u043c\u0435\u0441\u0442\u0438\u043c\u043e\u0441\u0442\u044c \u043d\u0435\u00a0\u0431\u0443\u0434\u0435\u0442 \u0441\u043e\u0431\u043b\u044e\u0434\u0435\u043d\u0430 \u0438 \u0441\u043e\u0445\u0440\u0430\u043d\u0438\u0442\u044c \u043d\u043e\u0432\u0443\u044e \u0432\u0435\u0440\u0441\u0438\u044e \u0441\u0445\u0435\u043c\u044b \u043d\u0435\u00a0\u043f\u043e\u043b\u0443\u0447\u0438\u0442\u0441\u044f.<\/p>\n<p>\u0422\u043e \u0435\u0441\u0442\u044c, \u0432\u00a0\u0442\u0435\u043a\u0443\u0449\u0435\u043c \u0442\u043e\u043f\u0438\u043a\u0435 \u044d\u0442\u0430 \u0441\u0445\u0435\u043c\u0430 \u043d\u0435\u00a0\u0431\u0443\u0434\u0435\u0442 \u0441\u043e\u0445\u0440\u0430\u043d\u0435\u043d\u0430 \u0438 \u043d\u0443\u0436\u043d\u043e \u0431\u0443\u0434\u0435\u0442 \u0441\u043e\u0437\u0434\u0430\u0432\u0430\u0442\u044c \u0434\u0440\u0443\u0433\u043e\u0439 \u0442\u043e\u043f\u0438\u043a. (\u0412 \u0442\u0430\u043a\u043e\u043c \u0441\u043b\u0443\u0447\u0430\u0435, \u043d\u0435\u043e\u0431\u0445\u043e\u0434\u0438\u043c\u043e \u0441\u043e\u0437\u0434\u0430\u0432\u0430\u0442\u044c \u043d\u043e\u0432\u044b\u0439 \u0442\u043e\u043f\u0438\u043a \u0432\u0435\u0440\u0441\u0438\u0438 2).<\/p>\n<p>\u041f\u043e\u0434\u0440\u043e\u0431\u043d\u0435\u0435 \u043e\u0431\u00a0\u0443\u0440\u043e\u0432\u043d\u044f\u0445 \u0441\u043e\u0432\u043c\u0435\u0441\u0442\u0438\u043c\u043e\u0441\u0442\u0438 <a href=\"https:\/\/docs.confluent.io\/platform\/current\/schema-registry\/avro.html#compatibility-types\"><u>\u0437\u0434\u0435\u0441\u044c<\/u><\/a>.<\/p>\n<h2>\u041f\u043e\u0434\u0432\u043e\u0434\u043d\u044b\u0435 \u043a\u0430\u043c\u043d\u0438 \u0440\u0430\u0431\u043e\u0442\u044b \u0441\u043e Schema Registry<\/h2>\n<p>\u041a\u0430\u043a \u0432\u0438\u0434\u0438\u0442\u0435, \u043f\u0440\u0438 \u0440\u0430\u0431\u043e\u0442\u0435 \u0441 \u0433\u043e\u0442\u043e\u0432\u044b\u043c\u0438 \u0431\u0438\u0431\u043b\u0438\u043e\u0442\u0435\u043a\u0430\u043c\u0438 Schema Registry \u043e\u0442 Confluent \u0432\u0441\u0435 \u0434\u043e\u0432\u043e\u043b\u044c\u043d\u043e \u043f\u0440\u043e\u0441\u0442\u043e. \u041d\u043e, \u043a\u0430\u043a \u044f \u0443\u0436\u0435 \u0433\u043e\u0432\u043e\u0440\u0438\u043b\u0430, \u0433\u043e\u0442\u043e\u0432\u044b\u0439 \u043a\u043b\u0438\u0435\u043d\u0442 \u0434\u043b\u044f SR \u0435\u0441\u0442\u044c \u043d\u0435 \u0434\u043b\u044f \u0432\u0441\u0435\u0445 \u044f\u0437\u044b\u043a\u043e\u0432, \u0430 \u0442\u043e\u043b\u044c\u043a\u043e \u0434\u043b\u044f <a href=\"https:\/\/docs.confluent.io\/5.4.3\/clients\/index.html#ak-clients\"><u>C\/C++, Python, go, Java, .NET<\/u><\/a>.<\/p>\n<p>\u0418 \u0441\u0430\u043c\u043e\u0435 \u0438\u043d\u0442\u0435\u0440\u0435\u0441\u043d\u043e\u0435 \u043d\u0430\u0447\u0438\u043d\u0430\u0435\u0442\u0441\u044f, \u043a\u043e\u0433\u0434\u0430 \u043d\u0435\u043e\u0431\u0445\u043e\u0434\u0438\u043c\u043e \u043d\u0430\u043f\u0438\u0441\u0430\u0442\u044c \u043f\u0440\u043e\u0434\u044e\u0441\u0435\u0440 \u0438\u043b\u0438 \u043a\u043e\u043d\u0441\u044c\u044e\u043c\u0435\u0440 \u043d\u0430 \u044f\u0437\u044b\u043a\u0435, \u0434\u043b\u044f \u043a\u043e\u0442\u043e\u0440\u043e\u0433\u043e \u043d\u0435\u0442 \u043d\u0430\u0442\u0438\u0432\u043d\u043e\u0439 \u0431\u0438\u0431\u043b\u0438\u043e\u0442\u0435\u043a\u0438.<\/p>\n<p>\u0412 \u043d\u0430\u0448\u0435\u043c \u043f\u0440\u043e\u0435\u043a\u0442\u0435, \u043c\u044b \u0441\u0442\u043e\u043b\u043a\u043d\u0443\u043b\u0438\u0441\u044c \u0441 \u0442\u0435\u043c, \u0447\u0442\u043e \u043d\u0435\u043e\u0431\u0445\u043e\u0434\u0438\u043c\u043e \u0431\u044b\u043b\u043e \u043d\u0430\u043f\u0438\u0441\u0430\u0442\u044c \u043f\u0440\u043e\u0434\u044e\u0441\u0435\u0440 \u043d\u0430 \u044f\u0437\u044b\u043a\u0435 PHP, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u0431\u044b\u043b \u0431\u044b \u0441\u043e\u0432\u043c\u0435\u0441\u0442\u0438\u043c \u0441 \u0440\u0430\u0431\u043e\u0442\u043e\u0439 SR. \u041f\u043e\u044d\u0442\u043e\u043c\u0443 \u0440\u0430\u0441\u0441\u043c\u043e\u0442\u0440\u0438\u043c \u043d\u0430 \u043f\u0440\u0438\u043c\u0435\u0440\u0435 \u043f\u0440\u043e\u0434\u044e\u0441\u0435\u0440\u0430, \u0447\u0442\u043e \u043e\u043d \u0434\u043e\u043b\u0436\u0435\u043d \u0434\u0435\u043b\u0430\u0442\u044c, \u0447\u0442\u043e\u0431\u044b \u0438\u043c\u0435\u0442\u044c \u0441\u043e\u0432\u043c\u0435\u0441\u0442\u0438\u043c\u043e\u0441\u0442\u044c \u0441 SR:<\/p>\n<ol>\n<li>\n<p>\u0417\u0430\u0440\u0435\u0433\u0438\u0441\u0442\u0440\u0438\u0440\u043e\u0432\u0430\u0442\u044c \u0441\u0445\u0435\u043c\u0443 \u0432 \u0441\u0435\u0440\u0432\u0435\u0440\u0435 Schema Registry.<\/p>\n<\/li>\n<li>\n<p>\u0421\u0435\u0440\u0438\u0430\u043b\u0438\u0437\u043e\u0432\u0430\u0442\u044c \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u0438\u0437 DTO \u0432 \u043d\u0430\u0431\u043e\u0440 \u0431\u0430\u0439\u0442\u043e\u0432.<\/p>\n<\/li>\n<li>\n<p>\u041e\u0442\u043f\u0440\u0430\u0432\u0438\u0442\u044c \u0435\u0433\u043e \u0432 \u043d\u0443\u0436\u043d\u044b\u0439 \u0442\u043e\u043f\u0438\u043a Kafka.<\/p>\n<\/li>\n<\/ol>\n<p>\u0421 \u0442\u0440\u0435\u0442\u044c\u0438\u043c \u043f\u0443\u043d\u043a\u0442\u043e\u043c \u0432\u0441\u0435 \u043f\u043e\u043d\u044f\u0442\u043d\u043e \u0438 \u043f\u0440\u043e\u0441\u0442\u043e. \u041f\u043e\u044d\u0442\u043e\u043c\u0443 \u0440\u0430\u0441\u0441\u043c\u043e\u0442\u0440\u0438\u043c \u043f\u0435\u0440\u0432\u044b\u0435 \u0434\u0432\u0430.<\/p>\n<h3>\u0417\u0430\u0440\u0435\u0433\u0438\u0441\u0442\u0440\u0438\u0440\u043e\u0432\u0430\u0442\u044c \u0441\u0445\u0435\u043c\u0443 \u0432 schema registry<\/h3>\n<p>\u0414\u043e\u0441\u0442\u0430\u0442\u043e\u0447\u043d\u043e \u0441\u043e\u0437\u0434\u0430\u0442\u044c \u043a\u043b\u0438\u0435\u043d\u0442 REST API \u0434\u043b\u044f\u00a0SR \u0438 \u043f\u043e\u043c\u043e\u0449\u044c\u044e \u043c\u0435\u0442\u043e\u0434\u0430 POST \u0441\u043e\u0437\u0434\u0430\u0442\u044c \u0438 \u0437\u0430\u0440\u0435\u0433\u0438\u0441\u0442\u0440\u0438\u0440\u043e\u0432\u0430\u0442\u044c \u0441\u0445\u0435\u043c\u0443 \u0432\u00a0\u043d\u0443\u0436\u043d\u043e\u043c \u043f\u0440\u043e\u0441\u0442\u0440\u0430\u043d\u0441\u0442\u0432\u0435 \u0438\u043c\u0435\u043d: <a href=\"https:\/\/docs.confluent.io\/platform\/current\/schema-registry\/develop\/api.html#mode\"><u>\u043f\u0440\u0438\u043c\u0435\u0440 \u0432\u00a0\u0434\u043e\u043a\u0443\u043c\u0435\u043d\u0442\u0430\u0446\u0438\u0438<\/u><\/a><\/p>\n<p>\u0417\u0434\u0435\u0441\u044c \u0432\u0430\u0436\u043d\u043e \u043f\u043e\u043c\u043d\u0438\u0442\u044c, \u0447\u0442\u043e\u00a0\u043f\u0440\u043e\u0441\u0442\u0440\u0430\u043d\u0441\u0442\u0432\u043e \u0438\u043c\u0435\u043d \u043d\u0435\u00a0\u0441\u043e\u0432\u043f\u0430\u0434\u0430\u0435\u0442 \u0441\u00a0\u043d\u0430\u0437\u0432\u0430\u043d\u0438\u0435\u043c \u0442\u043e\u043f\u0438\u043a\u0430 \u0432\u00a0\u0431\u0440\u043e\u043a\u0435\u0440\u0435 Kafka. \u041c\u044b \u0443\u0436\u0435 \u0433\u043e\u0432\u043e\u0440\u0438\u043b\u0438 \u043f\u0440\u043e\u00a0\u043f\u0440\u043e\u0441\u0442\u0440\u0430\u043d\u0441\u0442\u0432\u0430 \u0438\u043c\u0435\u043d \u0440\u0430\u043d\u0435\u0435 \u0438 \u0435\u0441\u043b\u0438 \u0432\u044b \u0432\u00a0\u043a\u043e\u043d\u0441\u044c\u044e\u043c\u0435\u0440\u0435 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u0435\u0442\u0435 \u043f\u0430\u0440\u0430\u043c\u0435\u0442\u0440 <code>serde.ValueSerde<\/code> \u043f\u0440\u0438\u00a0\u0441\u0435\u0440\u0438\u0430\u043b\u0438\u0437\u0430\u0446\u0438\u0438, \u0442\u043e \u0442\u043e\u043f\u0438\u043a\u0443 <code>topic.v1<\/code> \u0432\u00a0\u0431\u0440\u043e\u043a\u0435\u0440\u0435 Kafka \u0432\u00a0SR \u0431\u0443\u0434\u0435\u0442 \u0441\u043e\u043e\u0442\u0432\u0435\u0442\u0441\u0442\u0432\u043e\u0432\u0430\u0442\u044c \u043f\u0440\u043e\u0441\u0442\u0440\u0430\u043d\u0441\u0442\u0432\u043e \u0438\u043c\u0435\u043d <code>topic.v1-value<\/code>.<\/p>\n<h3>\u0421\u0435\u0440\u0438\u0430\u043b\u0438\u0437\u0430\u0446\u0438\u044f \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f<\/h3>\n<p>\u041c\u044b \u043d\u0435\u00a0\u043c\u043e\u0436\u0435\u043c \u043f\u0440\u043e\u0441\u0442\u043e \u0442\u0430\u043a \u0432\u0437\u044f\u0442\u044c \u0438 \u0441\u0435\u0440\u0438\u0430\u043b\u0438\u0437\u043e\u0432\u0430\u0442\u044c \u043d\u0430\u0448 DTO \u0432\u00a0\u043c\u0430\u0441\u0441\u0438\u0432 \u0431\u0430\u0439\u0442\u043e\u0432 \u0438 \u043e\u0442\u043f\u0440\u0430\u0432\u0438\u0442\u044c \u0435\u0433\u043e \u0432\u00a0\u043d\u0443\u0436\u043d\u044b\u0439 \u0442\u043e\u043f\u0438\u043a. \u0412\u0441\u0435 \u0441\u043b\u043e\u043c\u0430\u0435\u0442\u0441\u044f, \u043f\u043e\u0442\u043e\u043c\u0443 \u0447\u0442\u043e\u00a0\u043f\u0440\u0438\u00a0\u0441\u0435\u0440\u0438\u0430\u043b\u0438\u0437\u0430\u0446\u0438\u0438 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u0435\u0442\u0441\u044f \u0441\u043f\u0435\u0446\u0438\u0430\u043b\u044c\u043d\u044b\u0439 \u043f\u0440\u043e\u0442\u043e\u043a\u043e\u043b \u0438 \u0441\u043f\u0435\u0446\u0438\u0430\u043b\u044c\u043d\u044b\u0439 \u0441\u043f\u043e\u0441\u043e\u0431 \u043a\u043e\u0434\u0438\u0440\u043e\u0432\u0430\u043d\u0438\u044f.<\/p>\n<p><a href=\"https:\/\/docs.confluent.io\/platform\/current\/schema-registry\/serdes-develop\/index.html#wire-format\"><u>\u0412\u043e\u0442 \u0442\u0430\u043a<\/u><\/a> \u0432\u00a0\u043e\u0431\u0449\u0435\u043c \u0444\u043e\u0440\u043c\u0430\u0442\u0435 \u0432\u044b\u0433\u043b\u044f\u0434\u0438\u0442 \u0444\u043e\u0440\u043c\u0430\u0442 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439.<\/p>\n<p>\u0414\u043b\u044f\u00a0\u0444\u043e\u0440\u043c\u0430\u0442\u0430 Protobuf \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u0435\u0442\u0441\u044f \u0442\u0430\u043a\u043e\u0439 \u0444\u043e\u0440\u043c\u0430\u0442 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439:<\/p>\n<div>\n<div class=\"table\">\n<table>\n<tbody>\n<tr>\n<td data-colwidth=\"92\" width=\"92\">\n<p align=\"left\">\u0411\u0430\u0439\u0442\u044b<\/p>\n<\/td>\n<td data-colwidth=\"164\" width=\"164\">\n<p align=\"left\">\u041d\u0430\u0437\u0432\u0430\u043d\u0438\u0435<\/p>\n<\/td>\n<td>\n<p align=\"left\">\u041e\u043f\u0438\u0441\u0430\u043d\u0438\u0435<\/p>\n<\/td>\n<\/tr>\n<tr>\n<td data-colwidth=\"92\" width=\"92\">\n<p align=\"left\">0<\/p>\n<\/td>\n<td data-colwidth=\"164\" width=\"164\">\n<p align=\"left\">Magic Byte<\/p>\n<\/td>\n<td>\n<p align=\"left\">\u0420\u0430\u0432\u0435\u043d 0 \u0434\u043b\u044f \u0442\u0435\u043a\u0443\u0449\u0435\u0439 \u0432\u0435\u0440\u0441\u0438\u0438<\/p>\n<\/td>\n<\/tr>\n<tr>\n<td data-colwidth=\"92\" width=\"92\">\n<p align=\"left\">1-4<\/p>\n<\/td>\n<td data-colwidth=\"164\" width=\"164\">\n<p align=\"left\">Schema ID<\/p>\n<\/td>\n<td>\n<p align=\"left\">ID \u0441\u0445\u0435\u043c\u044b \u0432 SR, \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u044f ID \u0441\u0445\u0435\u043c\u044b \u0438 \u0438\u043c\u044f \u0442\u043e\u043f\u0438\u043a\u0430 \u0432\u0441\u0435\u0433\u0434\u0430 \u043e\u0434\u043d\u043e\u0437\u043d\u0430\u0447\u043d\u043e \u043c\u043e\u0436\u043d\u043e \u043e\u043f\u0440\u0435\u0434\u0435\u043b\u0438\u0442\u044c \u043d\u0443\u0436\u043d\u0443\u044e \u0441\u0445\u0435\u043c\u0443.<\/p>\n<\/td>\n<\/tr>\n<tr>\n<td data-colwidth=\"92\" width=\"92\">\n<p align=\"left\">5\u2026N<\/p>\n<\/td>\n<td data-colwidth=\"164\" width=\"164\">\n<p align=\"left\">Message Indexes<\/p>\n<\/td>\n<td>\n<p align=\"left\">\u0423\u043a\u0430\u0437\u044b\u0432\u0430\u0435\u0442 \u043d\u0430 \u0438\u043d\u0434\u0435\u043a\u0441 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f \u0432 Protobuf.<\/p>\n<p align=\"left\">\u0412 \u0441\u0430\u043c\u043e\u043c \u0447\u0430\u0441\u0442\u043e\u043c \u0441\u043b\u0443\u0447\u0430\u0435, \u0435\u0441\u043b\u0438 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u0435\u0442\u0441\u044f \u043f\u0435\u0440\u0432\u043e\u0435 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u0438\u0437 \u0441\u0445\u0435\u043c\u044b Protobuf, Message Index \u0431\u0443\u0434\u0435\u0442 \u0440\u0430\u0432\u0435\u043d 0<\/p>\n<\/td>\n<\/tr>\n<tr>\n<td data-colwidth=\"92\" width=\"92\">\n<p align=\"left\">N\u2026<\/p>\n<\/td>\n<td data-colwidth=\"164\" width=\"164\">\n<p align=\"left\">Data<\/p>\n<\/td>\n<td>\n<p align=\"left\">\u0421\u0435\u0440\u0438\u0430\u043b\u0438\u0437\u043e\u0432\u0430\u043d\u043d\u043e\u0435 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435<\/p>\n<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n<\/div>\n<\/div>\n<p>Message Indexes\u00a0\u2014 \u043e\u0434\u0438\u043d \u0438\u0437\u00a0\u0441\u0430\u043c\u044b\u0445 \u043d\u0435\u043e\u0447\u0435\u0432\u0438\u0434\u043d\u044b\u0445 \u043c\u043e\u043c\u0435\u043d\u0442\u043e\u0432. \u0418\u0437\u043d\u0430\u0447\u0430\u043b\u044c\u043d\u043e\u00a0\u2014 \u044d\u0442\u043e \u043c\u0430\u0441\u0441\u0438\u0432 \u0447\u0438\u0441\u0435\u043b, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u0442\u043e\u0447\u043d\u043e \u043e\u043f\u0440\u0435\u0434\u0435\u043b\u044f\u0435\u0442 \u0440\u0430\u0441\u043f\u043e\u043b\u043e\u0436\u0435\u043d\u0438\u0435 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f Protobuf \u0432\u00a0\u0441\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u0435.proto.<\/p>\n<p>\u041d\u0430\u043f\u0440\u0438\u043c\u0435\u0440, \u0443\u00a0\u043d\u0430\u0441 \u0435\u0441\u0442\u044c \u0441\u0445\u0435\u043c\u0430 \u0441\u00a0\u043c\u043d\u043e\u0436\u0435\u0441\u0442\u0432\u043e\u043c \u0432\u043b\u043e\u0436\u0435\u043d\u043d\u044b\u0445 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439:<\/p>\n<pre><code class=\"yaml\">package test.package;   message MessageA {     message Message B {         message Message C {         ...         }     }     message Message D {     ...     }     message Message E {         message Message F {         ...         }         message Message G {         ...         }     ...     } ... } message MessageH {     message MessageI {     ...     } }<\/code><\/pre>\n<p>\u0415\u0441\u043b\u0438 \u043c\u044b \u0437\u0430\u0445\u043e\u0442\u0438\u043c \u043e\u0442\u043f\u0440\u0430\u0432\u0438\u0442\u044c \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 Message G, \u0442\u043e \u0435\u0433\u043e \u0440\u0430\u0441\u043f\u043e\u043b\u043e\u0436\u0435\u043d\u0438\u0435 \u0432\u00a0\u0441\u0445\u0435\u043c\u0435 \u0431\u0443\u0434\u0435\u0442 \u043a\u043e\u0434\u0438\u0440\u043e\u0432\u0430\u0442\u044c\u0441\u044f \u0438\u043d\u0434\u0435\u043a\u0441\u0430\u043c\u0438 <code>[0, 2, 1]<\/code>: \u043e\u043d\u043e \u0432\u043b\u043e\u0436\u0435\u043d\u043e \u0432\u00a0\u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 A \u043d\u0430\u00a0\u0443\u0440\u043e\u0432\u043d\u0435 0, \u0432\u043b\u043e\u0436\u0435\u043d\u043e \u0432\u00a0\u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 E \u043d\u0430\u00a0\u0443\u0440\u043e\u0432\u043d\u0435 2\u00a0\u0438 \u0437\u0430\u043d\u0438\u043c\u0430\u0435\u0442 1\u00a0\u0443\u0440\u043e\u0432\u0435\u043d\u044c \u0432\u043d\u0443\u0442\u0440\u0438 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f E.<\/p>\n<p>\u0414\u0430\u043b\u0435\u0435 \u044d\u0442\u043e\u0442 \u0438\u043d\u0434\u0435\u043a\u0441 \u043a\u043e\u0434\u0438\u0440\u0443\u0435\u0442\u0441\u044f \u0441\u00a0\u043f\u043e\u043c\u043e\u0449\u044c\u044e variable\u2011length zig\u2011zag encoding (\u0437\u0438\u0433\u0437\u0430\u0433\u043e\u043e\u0431\u0440\u0430\u0437\u043d\u043e\u0435 \u043a\u043e\u0434\u0438\u0440\u043e\u0432\u0430\u043d\u0438\u0435 \u043f\u0435\u0440\u0435\u043c\u0435\u043d\u043d\u043e\u0439 \u0434\u043b\u0438\u043d\u044b), \u043a\u043e\u0442\u043e\u0440\u043e\u0435 \u0442\u0430\u043a\u0436\u0435 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u0435\u0442\u0441\u044f \u0432\u00a0Google Protocol Buffers, \u0438 \u043f\u043e\u043b\u0443\u0447\u0430\u0435\u0442\u0441\u044f \u043d\u0443\u0436\u043d\u044b\u0439 \u043d\u0430\u043c Message Indexes. \u041f\u043e\u0434\u0440\u043e\u0431\u043d\u0435\u0435 \u043e\u0431\u00a0\u0434\u0430\u043d\u043d\u043e\u043c \u0430\u043b\u0433\u043e\u0440\u0438\u0442\u043c\u0435 \u043a\u043e\u0434\u0438\u0440\u043e\u0432\u0430\u043d\u0438\u044f \u043c\u043e\u0436\u043d\u043e \u043f\u043e\u0447\u0438\u0442\u0430\u0442\u044c <a href=\"https:\/\/en.wikipedia.org\/wiki\/Variable-length_quantity#Zigzag_encoding\"><u>\u0437\u0434\u0435\u0441\u044c<\/u><\/a> \u0438 <a href=\"https:\/\/avro.apache.org\/docs\/1.11.1\/specification\/_print\/#primitive-types-1\"><u>\u0437\u0434\u0435\u0441\u044c<\/u><\/a>.<\/p>\n<p>\u041d\u043e\u00a0\u0432 \u0441\u0430\u043c\u043e\u043c \u0440\u0430\u0441\u043f\u0440\u043e\u0441\u0442\u0440\u0430\u043d\u0435\u043d\u043d\u043e\u043c \u0441\u043b\u0443\u0447\u0430\u0435, \u0435\u0441\u043b\u0438 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u0435\u0442\u0441\u044f \u043f\u0435\u0440\u0432\u043e\u0435 \u0438 \u0435\u0434\u0438\u043d\u0441\u0442\u0432\u0435\u043d\u043d\u043e\u0435 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u0438\u0437\u00a0Protobuf \u0441\u0445\u0435\u043c\u044b, \u0442\u043e Message Indexes \u0431\u0443\u0434\u0435\u0442 \u0440\u0430\u0432\u0435\u043d 0.<\/p>\n<p>\u0414\u043b\u044f\u00a0\u0442\u0435\u0445, \u043a\u0442\u043e \u0445\u043e\u0447\u0435\u0442 \u0443\u0433\u043b\u0443\u0431\u0438\u0442\u044c\u0441\u044f \u0432\u00a0\u0442\u043e, \u043a\u0430\u043a\u00a0\u0432\u044b\u0447\u0438\u0441\u043b\u044f\u0435\u0442\u0441\u044f Message Indexes, \u043c\u043e\u0436\u043d\u043e \u043f\u043e\u0441\u043c\u043e\u0442\u0440\u0435\u0442\u044c \u0438\u0441\u0445\u043e\u0434\u043d\u044b\u0439 \u043a\u043e\u0434 \u043d\u0430\u00a0\u043f\u0440\u0438\u043c\u0435\u0440\u0435 Go <a href=\"https:\/\/github.com\/confluentinc\/confluent-kafka-go\/blob\/master\/schemaregistry\/serde\/protobuf\/protobuf.go#L293\"><u>\u0437\u0434\u0435\u0441\u044c<\/u><\/a>.<\/p>\n<p>\u041e\u0441\u0442\u0430\u0432\u0448\u0438\u0435\u0441\u044f \u0431\u0430\u0439\u0442\u044b Data \u043f\u0440\u0435\u0434\u0441\u0442\u0430\u0432\u043b\u044f\u044e\u0442 \u0441\u0435\u0440\u0438\u0430\u043b\u0438\u0437\u043e\u0432\u0430\u043d\u043d\u043e\u0435 \u0432\u00a0\u043c\u0430\u0441\u0441\u0438\u0432 \u0431\u0430\u0439\u0442\u043e\u0432 \u0441\u00a0\u043f\u043e\u043c\u043e\u0449\u044c\u044e \u0444\u0443\u043d\u043a\u0446\u0438\u0438 <code>proto.Marshal(...)<\/code> \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435.<\/p>\n<p>\u0412\u0435\u0441\u044c \u043f\u0440\u043e\u0446\u0435\u0441\u0441 \u0441\u0435\u0440\u0438\u0430\u043b\u0438\u0437\u0430\u0446\u0438\u0438 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439 \u043d\u0430\u00a0\u043f\u0440\u0438\u043c\u0435\u0440\u0435 Go \u0432\u00a0\u0438\u0441\u0445\u043e\u0434\u043d\u0438\u043a\u0435 \u043c\u043e\u0436\u043d\u043e \u043f\u043e\u0441\u043c\u043e\u0442\u0440\u0435\u0442\u044c <a href=\"https:\/\/github.com\/confluentinc\/confluent-kafka-go\/blob\/master\/schemaregistry\/serde\/protobuf\/protobuf.go#L151\"><u>\u0437\u0434\u0435\u0441\u044c<\/u><\/a>.<\/p>\n<h2>\u0412\u044b\u0432\u043e\u0434\u044b<\/h2>\n<p>\u0412\u044b\u0432\u043e\u0434\u044b, \u043a\u043e\u0442\u043e\u0440\u044b\u0435 \u044f \u0441\u0434\u0435\u043b\u0430\u043b\u0430 \u0434\u043b\u044f\u00a0\u0441\u0435\u0431\u044f, \u043f\u043e\u0433\u0440\u0443\u0437\u0438\u0432\u0448\u0438\u0441\u044c \u0432\u00a0\u0434\u0438\u0432\u043d\u044b\u0439 \u043c\u0438\u0440 SR:<\/p>\n<ul>\n<li>\n<p>SR \u043f\u043e\u0437\u0432\u043e\u043b\u044f\u0435\u0442 \u043f\u043e\u0434\u0434\u0435\u0440\u0436\u0438\u0432\u0430\u0442\u044c \u0441\u043e\u0432\u043c\u0435\u0441\u0442\u0438\u043c\u043e\u0441\u0442\u044c \u0432\u00a0\u0440\u0430\u043c\u043a\u0430\u0445 \u043e\u0434\u043d\u043e\u0433\u043e \u043a\u043e\u043d\u0442\u0440\u0430\u043a\u0442\u0430, \u0433\u0430\u0440\u0430\u043d\u0442\u0438\u0440\u0443\u044f \u0442\u043e, \u0447\u0442\u043e\u00a0\u0432\u0441\u0435 \u0432\u0435\u0440\u0441\u0438\u0438 \u0441\u0445\u0435\u043c\u044b \u0431\u0443\u0434\u0443\u0442 \u0438\u043c\u0435\u0442\u044c \u043e\u0431\u0440\u0430\u0442\u043d\u0443\u044e \u0441\u043e\u0432\u043c\u0435\u0441\u0442\u0438\u043c\u043e\u0441\u0442\u044c \u0438 \u043f\u0440\u0438\u00a0\u0434\u0430\u043b\u044c\u043d\u0435\u0439\u0448\u0435\u0439 \u0440\u0430\u0437\u0440\u0430\u0431\u043e\u0442\u043a\u0435 \u043d\u0438\u0447\u0435\u0433\u043e \u043d\u0435\u00a0\u0441\u043b\u043e\u043c\u0430\u0435\u0442\u0441\u044f. \u0410\u00a0\u0435\u0441\u043b\u0438 \u043a\u043e\u043d\u0442\u0440\u0430\u043a\u0442 \u043b\u043e\u043c\u0430\u0435\u0442\u0441\u044f, \u0437\u043d\u0430\u0447\u0438\u0442 \u043f\u043e\u0440\u0430 \u043f\u0435\u0440\u0435\u0445\u043e\u0434\u0438\u0442\u044c \u043d\u0430\u00a0\u043d\u043e\u0432\u0443\u044e \u0432\u0435\u0440\u0441\u0438\u044e \u043a\u043e\u043d\u0442\u0440\u0430\u043a\u0442\u0430;<\/p>\n<\/li>\n<li>\n<p>SR \u0441\u043e\u0434\u0435\u0440\u0436\u0438\u0442 \u0432\u0441\u044e \u0438\u0441\u0442\u043e\u0440\u0438\u044e \u0438\u0437\u043c\u0435\u043d\u0435\u043d\u0438\u0439 \u043a\u043e\u043d\u0442\u0440\u0430\u043a\u0442\u0430;<\/p>\n<\/li>\n<li>\n<p>\u041f\u043e\u00a0\u0441\u0440\u0430\u0432\u043d\u0435\u043d\u0438\u044e \u0441\u00a0\u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u043d\u0438\u0435\u043c JSON \u0432\u043c\u0435\u0441\u0442\u0435 \u0441\u00a0Kafka, SR + Protobuf \u043e\u0447\u0435\u043d\u044c \u0441\u0438\u043b\u044c\u043d\u043e \u0443\u043f\u0440\u043e\u0449\u0430\u0435\u0442 \u0436\u0438\u0437\u043d\u044c \u0440\u0430\u0437\u0440\u0430\u0431\u043e\u0442\u0447\u0438\u043a\u0443 \u0432\u00a0\u043f\u043b\u0430\u043d\u0435 \u0440\u0430\u0431\u043e\u0442\u044b \u0441\u00a0DTO. \u041f\u043e\u0441\u043b\u0435\u0434\u043d\u044e\u044e \u0430\u043a\u0442\u0443\u0430\u043b\u044c\u043d\u0443\u044e \u0432\u0435\u0440\u0441\u0438\u044e \u0438\u0441\u0445\u043e\u0434\u043d\u0438\u043a\u0430 \u0441\u0445\u0435\u043c\u044b.proto \u043c\u043e\u0436\u043d\u043e \u0434\u0430\u0436\u0435 \u043d\u0435\u00a0\u043f\u0440\u043e\u0441\u0438\u0442\u044c \u0443\u00a0\u0441\u0432\u043e\u0435\u0433\u043e \u043a\u043e\u043b\u043b\u0435\u0433\u0438, \u0430\u00a0\u0441\u043a\u0430\u0447\u0430\u0442\u044c \u0441\u00a0\u043f\u043e\u043c\u043e\u0449\u044c\u044e \u043e\u0431\u044b\u0447\u043d\u043e\u0433\u043e REST API \u043a\u043b\u0438\u0435\u043d\u0442\u0430 \u0438\u0437\u00a0Schema Registry;<\/p>\n<\/li>\n<li>\n<p>\u041d\u0435\u0442 \u043d\u0435\u043e\u0431\u0445\u043e\u0434\u0438\u043c\u043e\u0441\u0442\u0438 \u0441\u043e\u0437\u0434\u0430\u0432\u0430\u0442\u044c \u043e\u0431\u0449\u0438\u0439 \u0440\u0435\u043f\u043e\u0437\u0438\u0442\u043e\u0440\u0438\u0439 \u0441\u043e \u0432\u0441\u0435\u043c\u0438 \u043a\u043e\u043d\u0442\u0440\u0430\u043a\u0442\u0430\u043c\u0438 \u0438 \u0441\u043b\u0435\u0434\u0438\u0442\u044c \u0437\u0430\u00a0\u0435\u0433\u043e \u043e\u0431\u043d\u043e\u0432\u043b\u0435\u043d\u0438\u0435\u043c. \u0418\u0441\u0445\u043e\u0434\u043d\u044b\u0439 \u0444\u0430\u0439\u043b.proto \u0445\u0440\u0430\u043d\u0438\u0442\u0441\u044f \u043d\u0430\u00a0\u0441\u0435\u0440\u0432\u0435\u0440\u0435 SR;<\/p>\n<\/li>\n<li>\n<p>SR\u00a0\u2014 \u044d\u0442\u043e\u00a0\u043b\u0438\u0448\u043d\u044f\u044f \u0441\u0443\u0449\u043d\u043e\u0441\u0442\u044c, \u0437\u0430\u00a0\u043a\u043e\u0442\u043e\u0440\u043e\u0439 \u043d\u0430\u0434\u043e \u0441\u043b\u0435\u0434\u0438\u0442\u044c. \u0425\u043e\u0440\u043e\u0448\u043e \u0440\u0430\u0431\u043e\u0442\u0430\u0435\u0442 \u0441\u00a0\u043a\u043b\u0438\u0435\u043d\u0442\u0430\u043c\u0438 \u0438\u0437\u00a0\u043a\u043e\u0440\u043e\u0431\u043a\u0438, \u043d\u043e\u00a0\u043c\u043e\u0436\u0435\u0442 \u0438\u0441\u043f\u043e\u0440\u0442\u0438\u0442\u044c \u0436\u0438\u0437\u043d\u044c \u043d\u0435\u0441\u043a\u043e\u043b\u044c\u043a\u0438\u043c \u043a\u043e\u043c\u0430\u043d\u0434\u0430\u043c, \u0435\u0441\u043b\u0438 \u043f\u0440\u0438\u0434\u0435\u0442\u0441\u044f \u043f\u0438\u0441\u0430\u0442\u044c \u0441\u0432\u043e\u0439 \u0441\u043e\u0431\u0441\u0442\u0432\u0435\u043d\u043d\u044b\u0439 \u043a\u043b\u0438\u0435\u043d\u0442;<\/p>\n<\/li>\n<li>\n<p>\u0414\u043e\u043a\u0443\u043c\u0435\u043d\u0442\u0430\u0446\u0438\u044f \u0434\u043b\u044f\u00a0SR \u043e\u0447\u0435\u043d\u044c \u043f\u043e\u0434\u0440\u043e\u0431\u043d\u0430\u044f, \u043d\u043e\u00a0\u0438\u0437\u2011\u0437\u0430 \u044d\u0442\u043e\u0433\u043e \u0441\u043b\u043e\u0436\u043d\u0430\u044f \u0434\u043b\u044f\u00a0\u0432\u043e\u0441\u043f\u0440\u0438\u044f\u0442\u0438\u044f. \u041e\u0433\u0440\u043e\u043c\u043d\u044b\u0439 \u043f\u043b\u044e\u0441 \u0432\u00a0\u0442\u043e\u043c, \u0447\u0442\u043e\u00a0\u0435\u0441\u0442\u044c \u0433\u043e\u0442\u043e\u0432\u044b\u0435 \u043f\u0440\u0438\u043c\u0435\u0440\u044b, \u0430\u00a0\u0438\u0441\u0445\u043e\u0434\u043d\u044b\u0439 \u043a\u043e\u0434 \u043e\u0442\u043a\u0440\u044b\u0442 \u0434\u043b\u044f\u00a0\u0438\u0437\u0443\u0447\u0435\u043d\u0438\u044f;<\/p>\n<\/li>\n<li>\n<p>\u0412\u00a0\u0441\u0435\u0442\u0438 \u043f\u043e\u00a0\u0434\u0430\u043d\u043d\u043e\u0439 \u0442\u0435\u043c\u0435 \u043e\u0447\u0435\u043d\u044c \u043c\u0430\u043b\u043e \u043e\u0431\u0443\u0447\u0430\u044e\u0449\u0438\u0445 \u0432\u0438\u0434\u0435\u043e, \u0441\u0442\u0430\u0442\u0435\u0439 \u0438 \u0432\u043e\u043f\u0440\u043e\u0441\u043e\u0432 \u0432\u00a0Stackoverflow. \u041d\u043e\u00a0\u0437\u0430\u0442\u043e \u043f\u0440\u044f\u043c\u043e \u0441\u0435\u0439\u0447\u0430\u0441 \u0441\u0442\u0430\u043b\u043e \u043d\u0430\u00a0\u043e\u0434\u043d\u0443 \u0441\u0442\u0430\u0442\u044c\u044e \u0431\u043e\u043b\u044c\u0448\u0435.<\/p>\n<\/li>\n<\/ul>\n<\/div>\n<\/div>\n<\/div>\n<p><!----><!----><\/div>\n<p><!----><!----><br \/> \u0441\u0441\u044b\u043b\u043a\u0430 \u043d\u0430 \u043e\u0440\u0438\u0433\u0438\u043d\u0430\u043b \u0441\u0442\u0430\u0442\u044c\u0438 <a href=\"https:\/\/habr.com\/ru\/articles\/715298\/\"> https:\/\/habr.com\/ru\/articles\/715298\/<\/a><\/p>\n","protected":false},"excerpt":{"rendered":"<div><!--[--><!--]--><\/div>\n<div id=\"post-content-body\">\n<div>\n<div class=\"article-formatted-body article-formatted-body article-formatted-body_version-2\">\n<div xmlns=\"http:\/\/www.w3.org\/1999\/xhtml\">\n<p>\u0412\u0441\u0435\u043c \u043f\u0440\u0438\u0432\u0435\u0442. \u041c\u0435\u043d\u044f \u0437\u043e\u0432\u0443\u0442 \u041d\u0438\u043d\u0430 \u041f\u0430\u043a\u0448\u0438\u043d\u0430, \u044f \u0440\u0430\u0437\u0440\u0430\u0431\u043e\u0442\u0447\u0438\u043a \u0432\u00a0\u043e\u0442\u0434\u0435\u043b\u0435 \u0420\u0430\u0437\u0440\u0430\u0431\u043e\u0442\u043a\u0438 \u0438 \u0443\u043f\u0440\u0430\u0432\u043b\u0435\u043d\u0438\u044f \u0446\u0438\u0444\u0440\u043e\u0432\u044b\u043c\u0438 \u043f\u0440\u043e\u0434\u0443\u043a\u0442\u0430\u043c\u0438 \u0438 \u0447\u0430\u0441\u0442\u044c \u043e\u043f\u0435\u0440\u0430\u0446\u0438\u043e\u043d\u043d\u043e\u0439 \u043a\u043e\u043c\u0430\u043d\u0434\u044b \u0432\u00a0\u0441\u0435\u0440\u0432\u0438\u0441\u0435 \u0434\u043e\u0441\u0442\u0430\u0432\u043a\u0438 \u043f\u0440\u043e\u0434\u0443\u043a\u0442\u043e\u0432 \u00ab\u041b\u0435\u043d\u0442\u0430 \u041e\u043d\u043b\u0430\u0439\u043d\u00bb. \u041d\u0430\u0448 \u0441\u0442\u0435\u043a PHP + Python + Go.<\/p>\n<p>\u041d\u0435\u0434\u0430\u0432\u043d\u043e \u044f \u0441\u0442\u043e\u043b\u043a\u043d\u0443\u043b\u0430\u0441\u044c \u0441\u00a0\u0434\u043e\u0432\u043e\u043b\u044c\u043d\u043e \u0442\u0440\u0438\u0432\u0438\u0430\u043b\u044c\u043d\u043e\u0439 \u0437\u0430\u0434\u0430\u0447\u0435\u0439: \u043d\u0443\u0436\u043d\u043e\u00a0\u0431\u044b\u043b\u043e \u0430\u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u043e \u043f\u043e\u043b\u0443\u0447\u0430\u0442\u044c \u0431\u043e\u043b\u044c\u0448\u043e\u0435 \u043a\u043e\u043b\u0438\u0447\u0435\u0441\u0442\u0432\u043e \u0434\u0430\u043d\u043d\u044b\u0445 \u0438\u0437\u00a0\u0434\u0440\u0443\u0433\u043e\u0433\u043e \u0441\u0435\u0440\u0432\u0438\u0441\u0430. \u0412\u00a0\u043a\u0430\u0447\u0435\u0441\u0442\u0432\u0435 \u0438\u043d\u0441\u0442\u0440\u0443\u043c\u0435\u043d\u0442\u0430 \u043e\u0431\u043c\u0435\u043d\u0430 \u0434\u0430\u043d\u043d\u044b\u043c\u0438 \u0441\u043e\u0432\u043c\u0435\u0441\u0442\u043d\u043e \u0441\u00a0\u043a\u043e\u043c\u0430\u043d\u0434\u043e\u0439 TMS, \u043a\u043e\u0442\u043e\u0440\u0430\u044f \u043e\u0442\u0432\u0435\u0447\u0430\u0435\u0442 \u0437\u0430\u00a0\u0443\u043f\u0440\u0430\u0432\u043b\u0435\u043d\u0438\u0435 \u0440\u0430\u0431\u043e\u0442\u043e\u0439 \u0441\u0431\u043e\u0440\u0449\u0438\u043a\u043e\u0432 \u0438 \u043a\u0443\u0440\u044c\u0435\u0440\u043e\u0432,\u00a0\u0431\u044b\u043b\u043e \u0440\u0435\u0448\u0435\u043d\u043e \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u044c \u0431\u0440\u043e\u043a\u0435\u0440 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439 Kafka.<\/p>\n<p>\u0422\u0430\u043a\u0436\u0435, \u043c\u0435\u0436\u0434\u0443 \u0440\u0430\u0437\u043b\u0438\u0447\u043d\u044b\u043c\u0438 \u043f\u0440\u043e\u0434\u0443\u043a\u0442\u043e\u0432\u044b\u043c\u0438 \u043a\u043e\u043c\u0430\u043d\u0434\u0430\u043c\u0438 \u043d\u0430\u0448\u0435\u0433\u043e \u0441\u0435\u0440\u0432\u0438\u0441\u0430 \u0441\u0443\u0449\u0435\u0441\u0442\u0432\u043e\u0432\u0430\u043b\u0430 \u0434\u043e\u0433\u043e\u0432\u043e\u0440\u0435\u043d\u043d\u043e\u0441\u0442\u044c \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u044c Kafka \u0432\u043c\u0435\u0441\u0442\u0435 \u0441\u00a0Schema Registry \u0438 Protobuf \u0432\u00a0\u043a\u0430\u0447\u0435\u0441\u0442\u0432\u0435 \u0444\u043e\u0440\u043c\u0430\u0442\u0430 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439.<\/p>\n<p>\u0421\u043e \u0441\u0442\u043e\u0440\u043e\u043d\u044b \u043d\u0430\u0448\u0435\u0439 \u043a\u043e\u043c\u0430\u043d\u0434\u044b \u043c\u044b \u0432\u043f\u0435\u0440\u0432\u044b\u0435 \u0440\u0435\u0430\u043b\u0438\u0437\u043e\u0432\u0430\u043b\u0438 \u0442\u0430\u043a\u0443\u044e \u0441\u0432\u044f\u0437\u043a\u0443, \u043f\u043e\u044d\u0442\u043e\u043c\u0443 \u0432\u00a0\u044d\u0442\u043e\u0439 \u0441\u0442\u0430\u0442\u044c\u0435 \u0445\u043e\u0447\u0443 \u043f\u043e\u0434\u0435\u043b\u0438\u0442\u044c\u0441\u044f \u0441\u0432\u043e\u0438\u043c \u043e\u043f\u044b\u0442\u043e\u043c \u043d\u0430\u043f\u0438\u0441\u0430\u043d\u0438\u044f \u043f\u0440\u043e\u0434\u044e\u0441\u0435\u0440\u0430 \u0438 \u043a\u043e\u043d\u0441\u044c\u044e\u043c\u0435\u0440\u0430 \u0441\u00a0\u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u043d\u0438\u0435\u043c Schema Registry \u043d\u0430\u00a0Go, \u0430\u00a0\u0442\u0430\u043a\u0436\u0435 \u0440\u0430\u0441\u0441\u043a\u0430\u0437\u0430\u0442\u044c \u043e\u00a0\u043f\u043e\u0434\u0432\u043e\u0434\u043d\u044b\u0445 \u043a\u0430\u043c\u043d\u044f\u0445, \u0441\u00a0\u043a\u043e\u0442\u043e\u0440\u044b\u043c\u0438 \u0432\u044b \u043c\u043e\u0436\u0435\u0442\u0435 \u0441\u0442\u043e\u043b\u043a\u043d\u0443\u0442\u044c\u0441\u044f.<\/p>\n<h2>\u0427\u0442\u043e \u0442\u0430\u043a\u043e\u0435 Schema Registry?<\/h2>\n<p>\u0415\u0441\u043b\u0438 \u043e\u0447\u0435\u043d\u044c \u0443\u043f\u0440\u043e\u0441\u0442\u0438\u0442\u044c\u00a0\u2014 <a href=\"https:\/\/docs.confluent.io\/platform\/current\/schema-registry\/\"><u>Schema Registry<\/u><\/a> (\u0434\u0430\u043b\u0435\u0435 SR)\u00a0\u2014 \u044d\u0442\u043e \u043e\u0442\u0434\u0435\u043b\u044c\u043d\u044b\u0439 \u043e\u0442\u00a0Kafka \u043a\u043e\u043c\u043f\u043e\u043d\u0435\u043d\u0442, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u044f\u0432\u043b\u044f\u0435\u0442\u0441\u044f \u0441\u0435\u0440\u0432\u0438\u0441\u043d\u044b\u043c \u0441\u043b\u043e\u0435\u043c \u0434\u043b\u044f\u00a0\u043c\u0435\u0442\u0430\u0434\u0430\u043d\u043d\u044b\u0445 Kafka \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439.<\/p>\n<p>\u041d\u0430\u00a0\u0440\u0438\u0441\u0443\u043d\u043a\u0435 1\u00a0\u2014 \u0441\u0445\u0435\u043c\u0430 \u0440\u0430\u0431\u043e\u0442\u044b SR \u0438\u0437\u00a0\u043e\u0444\u0438\u0446\u0438\u0430\u043b\u044c\u043d\u043e\u0439 \u0434\u043e\u043a\u0443\u043c\u0435\u043d\u0442\u0430\u0446\u0438\u0438 \u043e\u0442\u00a0Confluentic.<\/p>\n<figure class=\"full-width\"><figcaption>\u0420\u0438\u0441 1. \u041a\u0430\u043a \u0440\u0430\u0431\u043e\u0442\u0430\u0435\u0442 Schema Registry<\/figcaption><\/figure>\n<p>SR, \u043f\u043e\u00a0\u0441\u0443\u0442\u0438 \u044f\u0432\u043b\u044f\u0435\u0442\u0441\u044f \u043f\u0440\u043e\u0441\u043b\u043e\u0439\u043a\u043e\u0439 \u043c\u0435\u0436\u0434\u0443 Kafka \u0438 \u043a\u043b\u0438\u0435\u043d\u0442\u0441\u043a\u0438\u043c \u043f\u0440\u043e\u0434\u044e\u0441\u0435\u0440\u043e\u043c\/\u043a\u043e\u043d\u0441\u044c\u044e\u043c\u0435\u0440\u043e\u043c, \u0430\u00a0\u0433\u043b\u0430\u0432\u043d\u0430\u044f \u0437\u0430\u0434\u0430\u0447\u0430 \u043a\u043b\u0438\u0435\u043d\u0442\u0430 \u0438 \u0441\u0435\u0440\u0432\u0435\u0440\u0430 SR\u00a0\u2014 \u043f\u043e\u0434\u0434\u0435\u0440\u0436\u0438\u0432\u0430\u0442\u044c \u0441\u043e\u0432\u043c\u0435\u0441\u0442\u0438\u043c\u043e\u0441\u0442\u044c \u043c\u0435\u0436\u0434\u0443 \u0440\u0430\u0437\u043b\u0438\u0447\u043d\u044b\u043c\u0438 \u0432\u0435\u0440\u0441\u0438\u044f\u043c\u0438 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439 \u0438 \u0432\u0430\u043b\u0438\u0434\u0438\u0440\u043e\u0432\u0430\u0442\u044c \u0438\u0445 \u0441\u043e\u0433\u043b\u0430\u0441\u043d\u043e \u0437\u0430\u0434\u0430\u043d\u043d\u043e\u0439 \u0441\u0445\u0435\u043c\u044b.<\/p>\n<p>SR \u0445\u0440\u0430\u043d\u0438\u0442 \u0432\u00a0\u0441\u0435\u0431\u0435 \u043d\u0435\u00a0\u0442\u043e\u043b\u044c\u043a\u043e \u0442\u0435\u043a\u0443\u0449\u0443\u044e \u0441\u0445\u0435\u043c\u0443, \u043d\u043e\u00a0\u0438 \u0432\u0441\u044e \u0438\u0441\u0442\u043e\u0440\u0438\u044e \u0438\u0437\u043c\u0435\u043d\u0435\u043d\u0438\u0439, \u0440\u0430\u0431\u043e\u0442\u0430\u0435\u0442 \u0441\u00a0\u0444\u043e\u0440\u043c\u0430\u0442\u0430\u043c\u0438 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439 <a href=\"https:\/\/avro.apache.org\/\"><u>Avro<\/u><\/a>, <a href=\"https:\/\/json-schema.org\/\"><u>Json Schema<\/u><\/a> \u0438\u043b\u0438 <a href=\"https:\/\/developers.google.com\/protocol-buffers\/\"><u>Protocol buffers<\/u><\/a>, \u0430\u00a0\u0442\u0430\u043a\u0436\u0435 \u0441\u043b\u0435\u0434\u0438\u0442 \u0437\u0430\u00a0\u043e\u0431\u0440\u0430\u0442\u043d\u043e\u0439 \u0441\u043e\u0432\u043c\u0435\u0441\u0442\u0438\u043c\u043e\u0441\u0442\u044c\u044e \u043f\u0435\u0440\u0435\u0434\u0430\u0432\u0430\u0435\u043c\u044b\u0445 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439.<\/p>\n<p>SR \u0438\u043c\u0435\u0435\u0442 \u0441\u0432\u043e\u0439 RESTfull \u0438\u043d\u0442\u0435\u0440\u0444\u0435\u0439\u0441, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u043f\u0440\u0435\u0434\u043e\u0441\u0442\u0430\u0432\u043b\u044f\u0435\u0442 \u0434\u043e\u0441\u0442\u0443\u043f \u043a\u043e \u0432\u0441\u0435\u043c \u0434\u0435\u0439\u0441\u0442\u0432\u0438\u044f\u043c \u043d\u0430\u0434 \u0441\u0445\u0435\u043c\u0430\u043c\u0438 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439 (\u0441\u043e\u0437\u0434\u0430\u043d\u0438\u0435, \u0447\u0442\u0435\u043d\u0438\u0435, \u0443\u0434\u0430\u043b\u0435\u043d\u0438\u0435 \u0438 \u0442\u0434).<\/p>\n<h2>\u041a\u0430\u043a \u0440\u0430\u0431\u043e\u0442\u0430\u0435\u0442 SR?<\/h2>\n<p>\u041d\u0430\u00a0\u043f\u0440\u0438\u043c\u0435\u0440\u0435 \u0441\u0432\u044f\u0437\u043a\u0438 Kafka + Schema Registry + Protobuf, \u0440\u0430\u0441\u0441\u043c\u043e\u0442\u0440\u0438\u043c \u0432\u00a0\u0443\u043f\u0440\u043e\u0449\u0435\u043d\u043d\u043e\u0439 \u0441\u0445\u0435\u043c\u0435 \u043a\u0430\u043a\u00a0\u0440\u0430\u0431\u043e\u0442\u0430\u0435\u0442 SR (\u0441 \u043e\u0441\u0442\u0430\u043b\u044c\u043d\u044b\u043c\u0438 \u0444\u043e\u0440\u043c\u0430\u0442\u0430\u043c\u0438 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439 \u0432\u0441\u0435 \u043f\u043e\u0445\u043e\u0436\u0435, \u043d\u043e\u00a0\u0435\u0441\u0442\u044c \u0441\u0432\u043e\u0438 \u043d\u044e\u0430\u043d\u0441\u044b):<\/p>\n<ol>\n<li>\n<p>\u0412\u00a0\u0440\u0435\u043f\u043e\u0437\u0438\u0442\u043e\u0440\u0438\u0438 \u043f\u0440\u043e\u0434\u044e\u0441\u0435\u0440\u0430 Kafka \u0441\u043e\u0437\u0434\u0430\u0435\u0442\u0441\u044f, \u0441\u043e\u0445\u0440\u0430\u043d\u044f\u0435\u0442\u0441\u044f \u0438 \u043a\u043e\u043c\u043f\u0438\u043b\u0438\u0440\u0443\u0435\u0442\u0441\u044f \u043d\u0430\u00a0\u043d\u0443\u0436\u043d\u044b\u0439 \u044f\u0437\u044b\u043a \u0432\u00a0\u043e\u0431\u044a\u0435\u043a\u0442\u2011\u0441\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u0443 DTO \u0441\u0445\u0435\u043c\u0430 Protobuf.proto;<\/p>\n<\/li>\n<li>\n<p>\u041f\u0440\u0438\u00a0\u043e\u0442\u043f\u0440\u0430\u0432\u043a\u0435 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f, \u0435\u0441\u043b\u0438 \u0441\u0445\u0435\u043c\u0430 \u0435\u0449\u0435 \u043d\u0435\u00a0\u0431\u044b\u043b\u0430 \u0437\u0430\u0440\u0435\u0433\u0438\u0441\u0442\u0440\u0438\u0440\u043e\u0432\u0430\u043d\u0430 \u0432\u00a0SR, \u043a\u043b\u0438\u0435\u043d\u0442 SR \u0440\u0435\u0433\u0438\u0441\u0442\u0440\u0438\u0440\u0443\u0435\u0442 \u0435\u0435 \u0438 \u0434\u0430\u0435\u0442 \u0435\u0439 id \u0432\u0435\u0440\u0441\u0438\u0438. \u0415\u0441\u043b\u0438 \u0441\u0445\u0435\u043c\u0430 \u0443\u0436\u0435\u00a0\u0431\u044b\u043b\u0430 \u0437\u0430\u0440\u0435\u0433\u0438\u0441\u0442\u0440\u0438\u0440\u043e\u0432\u0430\u043d\u0430, \u0442\u043e \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u0435\u0442\u0441\u044f \u0441\u0443\u0449\u0435\u0441\u0442\u0432\u0443\u044e\u0449\u0438\u0439 id;<\/p>\n<\/li>\n<li>\n<p>\u0421\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u043e\u043f\u0440\u0435\u0434\u0435\u043b\u0435\u043d\u043d\u044b\u043c \u043e\u0431\u0440\u0430\u0437\u043e\u043c, \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u044f id \u0441\u0445\u0435\u043c\u044b, \u0441\u0435\u0440\u0438\u0430\u043b\u0438\u0437\u0443\u0435\u0442\u0441\u044f \u0438 \u043e\u0442\u043f\u0440\u0430\u0432\u043b\u044f\u0435\u0442\u0441\u044f \u0432\u00a0\u0431\u0440\u043e\u043a\u0435\u0440 Kafka;<\/p>\n<\/li>\n<li>\n<p>\u0420\u0435\u043f\u043e\u0437\u0438\u0442\u043e\u0440\u0438\u0439 \u043a\u043e\u043d\u0441\u044c\u044e\u043c\u0435\u0440\u0430 \u043d\u0435\u00a0\u0445\u0440\u0430\u043d\u0438\u0442 \u0432\u00a0\u0441\u0435\u0431\u0435 \u0438\u0441\u0445\u043e\u0434\u043d\u0443\u044e \u0441\u0445\u0435\u043c\u0443 Protobuf.proto, \u0430\u00a0\u0438\u043c\u0435\u0435\u0442 \u0442\u043e\u043b\u044c\u043a\u043e \u0441\u043a\u043e\u043c\u043f\u0438\u043b\u0438\u0440\u043e\u0432\u0430\u043d\u043d\u0443\u044e \u043d\u0430\u00a0\u043d\u0443\u0436\u043d\u044b\u0439 \u044f\u0437\u044b\u043a \u043e\u0431\u044a\u0435\u043a\u0442\u2011\u0441\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u0443 DTO;<\/p>\n<\/li>\n<li>\n<p>\u041a\u043e\u043d\u0441\u044c\u044e\u043c\u0435\u0440 \u043f\u043e\u043b\u0443\u0447\u0430\u0435\u0442 \u0441\u0435\u0440\u0438\u0430\u043b\u0438\u0437\u043e\u0432\u0430\u043d\u043d\u043e\u0435 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u0438\u0437\u00a0Kafka. \u0417\u0430\u0442\u0435\u043c \u043f\u043e\u00a0id \u0432\u0435\u0440\u0441\u0438\u0438 \u0441\u0445\u0435\u043c\u044b \u043f\u043e\u043b\u0443\u0447\u0430\u0435\u0442 \u0441\u0445\u0435\u043c\u0443 \u0438\u0437\u00a0SR \u0438 \u0434\u0435\u0441\u0435\u0440\u0438\u0430\u043b\u0438\u0437\u0443\u0435\u0442 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u0432\u00a0DTO.<\/p>\n<\/li>\n<\/ol>\n<h2>\u041f\u0438\u0448\u0435\u043c \u043f\u0440\u0438\u043c\u0435\u0440\u044b \u043d\u0430 Go<\/h2>\n<p>\u042f \u043d\u0435\u00a0\u0431\u0443\u0434\u0443 \u0440\u0430\u0441\u0441\u043a\u0430\u0437\u044b\u0432\u0430\u0442\u044c, \u043a\u0430\u043a\u00a0\u043f\u043e\u0434\u043d\u0438\u043c\u0430\u0442\u044c \u0438 \u043d\u0430\u0441\u0442\u0440\u0430\u0438\u0432\u0430\u0442\u044c \u0441\u0432\u044f\u0437\u043a\u0443 Kafka + Schema Registry. \u0414\u043b\u044f\u00a0\u043b\u043e\u043a\u0430\u043b\u044c\u043d\u043e\u0433\u043e \u0442\u0435\u0441\u0442\u0438\u0440\u043e\u0432\u0430\u043d\u0438\u044f \u0432\u044b \u043c\u043e\u0436\u0435\u0442\u0435 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u044c \u0443\u0436\u0435 \u0433\u043e\u0442\u043e\u0432\u044b\u0439 <a href=\"https:\/\/github.com\/confluentinc\/schema-registry-workshop\/blob\/master\/docker-compose.yml\"><u>docker\u2011compose<\/u><\/a> \u0444\u0430\u0439\u043b \u0438 \u0437\u0430\u043f\u0443\u0441\u0442\u0438\u0442\u044c \u0441\u0438\u0441\u0442\u0435\u043c\u0443 \u0443\u00a0\u0441\u0435\u0431\u044f \u0432\u00a0\u0434\u043e\u043a\u0435\u0440\u0435.<\/p>\n<p>\u0414\u043b\u044f\u00a0\u0440\u0430\u0431\u043e\u0442\u044b \u043d\u0430\u043c \u043f\u043e\u043d\u0430\u0434\u043e\u0431\u0438\u0442\u0441\u044f \u0431\u0440\u043e\u043a\u0435\u0440 Kafka \u0438 \u0441\u0435\u0440\u0432\u0435\u0440 Schema Registry \u0441\u00a0\u0438\u0437\u0432\u0435\u0441\u0442\u043d\u044b\u043c\u0438 \u043d\u0430\u043c \u0430\u0434\u0440\u0435\u0441\u0430\u043c\u0438, \u043a\u043e\u0442\u043e\u0440\u044b\u0435 \u043e\u0431\u043e\u0437\u043d\u0430\u0447\u0438\u043c \u043a\u0430\u043a <code>kafkaURL<\/code> \u0438 <code>srURL<\/code> \u0441\u043e\u043e\u0442\u0432\u0435\u0442\u0441\u0442\u0432\u0435\u043d\u043d\u043e.<\/p>\n<p>\u0414\u043b\u044f\u00a0\u0440\u0430\u0431\u043e\u0442\u044b \u0441\u00a0SR \u043d\u0430\u00a0\u044f\u0437\u044b\u043a\u0435 Go\u00a0\u0431\u044b\u043b\u043e \u043d\u0435\u0441\u043a\u043e\u043b\u044c\u043a\u043e \u0432\u0430\u0440\u0438\u0430\u043d\u0442\u043e\u0432: <\/p>\n<ul>\n<li>\n<p>\u041d\u0430\u043f\u0438\u0441\u0430\u0442\u044c \u043a\u043b\u0438\u0435\u043d\u0442 SR \u0441\u0430\u043c\u043e\u0441\u0442\u043e\u044f\u0442\u0435\u043b\u044c\u043d\u043e, \u0443\u0447\u0438\u0442\u044b\u0432\u0430\u044f \u0432\u0441\u0435 \u043d\u044e\u0430\u043d\u0441\u044b \u0432\u0437\u0430\u0438\u043c\u043e\u0434\u0435\u0439\u0441\u0442\u0432\u0438\u044f;<\/p>\n<\/li>\n<li>\n<p>\u0418\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u044c \u043d\u0430\u0442\u0438\u0432\u043d\u044b\u0439 \u043a\u043b\u0438\u0435\u043d\u0442 \u043e\u0442 <a href=\"https:\/\/www.confluent.io\/\"><u>Confluent<\/u><\/a>, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u043d\u0430\u0437\u044b\u0432\u0430\u0435\u0442\u0441\u044f <a href=\"https:\/\/github.com\/confluentinc\/confluent-kafka-go\"><u>confluent\u2011kafka\u2011go<\/u><\/a>.<\/p>\n<\/li>\n<\/ul>\n<p>\u041d\u0430\u0442\u0438\u0432\u043d\u044b\u0439 \u043a\u043b\u0438\u0435\u043d\u0442 \u043e\u0442\u00a0Confluent \u0435\u0441\u0442\u044c \u043d\u0435\u00a0\u0434\u043b\u044f\u00a0\u0432\u0441\u0435\u0445 \u044f\u0437\u044b\u043a\u043e\u0432, \u0430\u00a0\u0442\u043e\u043b\u044c\u043a\u043e \u0434\u043b\u044f <a href=\"https:\/\/docs.confluent.io\/5.4.3\/clients\/index.html#ak-clients\"><u>C\/C++, Python, Golang, Java,.NET<\/u><\/a>.<\/p>\n<p>\u041f\u043e\u044d\u0442\u043e\u043c\u0443, \u0442\u0430\u043a \u043a\u0430\u043a\u00a0\u043c\u043d\u0435 \u043f\u043e\u0432\u0435\u0437\u043b\u043e, \u044f \u0440\u0435\u0448\u0438\u043b\u0430 \u043f\u043e\u0439\u0442\u0438 \u0431\u043e\u043b\u0435\u0435 \u043f\u0440\u043e\u0441\u0442\u044b\u043c \u043f\u0443\u0442\u0435\u043c \u0438 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u044c \u0433\u043e\u0442\u043e\u0432\u044b\u0439 \u043a\u043b\u0438\u0435\u043d\u0442, \u0442\u0435\u043c \u0431\u043e\u043b\u0435\u0435 \u0447\u0442\u043e\u00a0\u0434\u043b\u044f\u00a0\u043d\u0435\u0433\u043e \u0441\u0443\u0449\u0435\u0441\u0442\u0432\u0443\u0435\u0442 \u0434\u043e\u0441\u0442\u0430\u0442\u043e\u0447\u043d\u043e \u043f\u043e\u0434\u0440\u043e\u0431\u043d\u0430\u044f \u0434\u043e\u043a\u0443\u043c\u0435\u043d\u0442\u0430\u0446\u0438\u044f \u0438 \u043d\u0435\u0441\u043a\u043e\u043b\u044c\u043a\u043e \u0440\u0430\u0431\u043e\u0447\u0438\u0445 \u043f\u0440\u0438\u043c\u0435\u0440\u043e\u0432.<\/p>\n<h3>\u0428\u0430\u0433 1: \u043f\u0440\u043e\u0434\u044e\u0441\u0435\u0440<\/h3>\n<p>\u041d\u0430\u043f\u0438\u0448\u0435\u043c SR \u043f\u0440\u043e\u0434\u044e\u0441\u0435\u0440 SRProducer, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u043f\u043e\u0437\u0432\u043e\u043b\u0438\u0442 \u0440\u0435\u0433\u0438\u0441\u0442\u0440\u0438\u0440\u043e\u0432\u0430\u0442\u044c \u0441\u0445\u0435\u043c\u0443 \u0432\u00a0SR \u0434\u043b\u044f\u00a0\u0444\u043e\u0440\u043c\u0430\u0442\u0430 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439 Protobuf \u0438 \u043e\u0442\u043f\u0440\u0430\u0432\u043b\u044f\u0442\u044c \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f \u0432\u00a0Kafka.<\/p>\n<p>\u041f\u043e\u043b\u043d\u044b\u0439 \u043a\u043e\u0434 SR \u043f\u0440\u043e\u0434\u044e\u0441\u0435\u0440\u0430 \u043c\u043e\u0436\u043d\u043e \u043f\u043e\u0441\u043c\u043e\u0442\u0440\u0435\u0442\u044c <a href=\"https:\/\/github.com\/PakshNina\/sr\/blob\/main\/internal\/kafka\/producer.go\"><u>\u0437\u0434\u0435\u0441\u044c<\/u><\/a>.<\/p>\n<pre><code class=\"go\">\/\/ SRProducer \u0438\u043d\u0442\u0435\u0440\u0444\u0435\u0439\u0441, \u0440\u0435\u0430\u043b\u0438\u0437\u0443\u044e\u0449\u0438\u0439 \u043c\u0435\u0442\u043e\u0434\u044b \u043f\u0440\u043e\u0434\u044e\u0441\u0435\u0440\u0430 SR type SRProducer interface {   ProduceMessage(msg proto.Message, topic string) (int64, error)   Close() }  type srProducer struct {   producer   *kafka.Producer   serializer serde.Serializer }  \/\/ NewProducer \u0432\u043e\u0437\u0432\u0440\u0430\u0449\u0430\u0435\u0442 \u043f\u0440\u043e\u0434\u044e\u0441\u0435\u0440 SR \u0434\u043b\u044f \u0440\u0430\u0431\u043e\u0442\u044b \u0441 kafka \u0438 schema registry func NewProducer(kafkaURL, srURL string) (SRProducer, error) {   p, err := kafka.NewProducer(&amp;kafka.ConfigMap{\"bootstrap.servers\": kafkaURL})   if err != nil {      return nil, err   }   c, err := schemaregistry.NewClient(schemaregistry.NewConfig(srURL))   if err != nil {      return nil, err   }   s, err := protobuf.NewSerializer(c, serde.ValueSerde, protobuf.NewSerializerConfig())   if err != nil {      return nil, err   }   return &amp;srProducer{      producer:   p,      serializer: s,   }, nil }<\/code><\/pre>\n<p>NewProducer \u0432\u043e\u0437\u0432\u0440\u0430\u0449\u0430\u0435\u0442 SR \u043f\u0440\u043e\u0434\u044e\u0441\u0435\u0440, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u0440\u0435\u0430\u043b\u0438\u0437\u0443\u0435\u0442 \u0438\u043d\u0442\u0435\u0440\u0444\u0435\u0439\u0441 SRProducer.<\/p>\n<p>\u0414\u043b\u044f\u00a0\u0440\u0430\u0431\u043e\u0442\u044b \u043d\u0430\u0448\u0435\u0433\u043e \u043f\u0440\u043e\u0434\u044e\u0441\u0435\u0440\u0430 \u043d\u0435\u043e\u0431\u0445\u043e\u0434\u0438\u043c\u043e \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0438\u0442\u044c:<\/p>\n<ul>\n<li>\n<p>\u043f\u0440\u043e\u0434\u044e\u0441\u0435\u0440 Kafka <code>kafka.NewProducer(...)<\/code>;<\/p>\n<\/li>\n<\/ul>\n<ul>\n<li>\n<p>\u043a\u043b\u0438\u0435\u043d\u0442 REST API Schema Regisftry <code>schemaregistry.NewClient(...)<\/code>;<\/p>\n<\/li>\n<li>\n<p>\u0441\u0435\u0440\u0438\u0430\u043b\u0438\u0437\u0430\u0442\u043e\u0440 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439 \u0432\u00a0\u0444\u043e\u0440\u043c\u0430\u0442 Protobuf <code>protobuf.NewSerializer(...)<\/code>.<\/p>\n<\/li>\n<\/ul>\n<p>\u041e\u0431\u0440\u0430\u0442\u0438\u0442\u0435 \u0432\u043d\u0438\u043c\u0430\u043d\u0438\u0435, \u0447\u0442\u043e\u00a0\u043f\u0440\u0438\u00a0\u0441\u043e\u0437\u0434\u0430\u043d\u0438\u0438 \u0441\u0435\u0440\u0438\u0430\u043b\u0438\u0437\u0430\u0442\u043e\u0440\u0430 <code>protobuf.NewSerializer(...)<\/code> \u043f\u0435\u0440\u0435\u0434\u0430\u0435\u0442\u0441\u044f \u043f\u0430\u0440\u0430\u043c\u0435\u0442\u0440 <code>serde.ValueSerde<\/code>. \u0417\u0430\u043f\u043e\u043c\u043d\u0438\u043c \u044d\u0442\u043e \u043c\u0435\u0441\u0442\u043e \u0438 \u0447\u0443\u0442\u044c \u0434\u0430\u043b\u044c\u0448\u0435 \u043e\u0431\u0441\u0443\u0434\u0438\u043c, \u0447\u0442\u043e\u00a0\u043e\u043d \u0437\u043d\u0430\u0447\u0438\u0442.<\/p>\n<p>SR \u043f\u0440\u043e\u0434\u044e\u0441\u0435\u0440 <code>SRProducer<\/code> \u0440\u0435\u0430\u043b\u0438\u0437\u0443\u0435\u0442 \u0434\u0432\u0430 \u043c\u0435\u0442\u043e\u0434\u0430: <code>ProduceMessage<\/code>, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u0440\u0435\u0433\u0438\u0441\u0442\u0440\u0438\u0440\u0443\u0435\u0442 \u0441\u0445\u0435\u043c\u0443 \u0438 \u043e\u0442\u043f\u0440\u0430\u0432\u043b\u044f\u0435\u0442 \u0434\u0430\u043d\u043d\u044b\u0435 \u0432\u00a0Kafka, \u0430\u00a0\u0442\u0430\u043a\u0436\u0435 <code>Close<\/code> \u0434\u043b\u044f\u00a0\u0437\u0430\u043a\u0440\u044b\u0442\u0438\u044f \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u0439.<\/p>\n<pre><code class=\"go\">const (   nullOffset = -1 )  \/\/ ProduceMessage \u043e\u0442\u043f\u0440\u0430\u0432\u043b\u044f\u0435\u0442 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 proto.Message \u0432 \u043e\u043f\u0440\u0435\u0434\u0435\u043b\u0435\u043d\u043d\u044b\u0439 \u0442\u043e\u043f\u0438\u043a func (p *srProducer) ProduceMessage(msg proto.Message, topic string) (int64, error) {   kafkaChan := make(chan kafka.Event)   defer close(kafkaChan)   payload, err := p.serializer.Serialize(topic, msg)   if err != nil {      return nullOffset, err   }   if err = p.producer.Produce(&amp;kafka.Message{      TopicPartition: kafka.TopicPartition{Topic: &amp;topic},      Value:          payload,   }, kafkaChan); err != nil {      return nullOffset, err   }   e := &lt;-kafkaChan   switch ev := e.(type) {   case *kafka.Message:      return int64(ev.TopicPartition.Offset), nil   case kafka.Error:      return nullOffset, err   }   return nullOffset, nil }  \/\/ Close \u0437\u0430\u043a\u0440\u044b\u0432\u0430\u0435\u0442 \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u0435 \u0441 schema registry \u0438 kafka func (p *srProducer) Close() {   p.serializer.Close()   p.producer.Close() }<\/code><\/pre>\n<p>\u041c\u0435\u0442\u043e\u0434 <code>ProduceMessage<\/code> \u043e\u0442\u043f\u0440\u0430\u0432\u043b\u044f\u0435\u0442 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f \u0442\u0438\u043f\u0430 <code>proto.Message<\/code> \u0432\u00a0Kafka. \u041f\u0435\u0440\u0435\u0434 \u043e\u0442\u043f\u0440\u0430\u0432\u043a\u043e\u0439 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u0441\u0435\u0440\u0438\u0430\u043b\u0438\u0437\u0443\u0435\u0442\u0441\u044f.<\/p>\n<p>\u0417\u0430\u0442\u0435\u043c, \u0441\u00a0\u043f\u043e\u043c\u043e\u0449\u044c\u044e \u043c\u0435\u0442\u043e\u0434\u0430 <code>p.producer.Produce<\/code> \u043f\u0440\u043e\u0434\u044e\u0441\u0435\u0440\u0430 Kafka \u043c\u044b \u043e\u0442\u043f\u0440\u0430\u0432\u043b\u044f\u0435\u043c \u0441\u0435\u0440\u0438\u0430\u043b\u0438\u0437\u043e\u0432\u0430\u043d\u043d\u043e\u0435 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u0432\u00a0\u0431\u0440\u043e\u043a\u0435\u0440. \u041e\u0442\u0447\u0435\u0442 \u043e\u0431\u00a0\u043e\u0442\u043f\u0440\u0430\u0432\u043a\u0435 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f \u043f\u0440\u0438\u0445\u043e\u0434\u0438\u0442 \u0432\u00a0\u043a\u0430\u043d\u0430\u043b <code>kafka.Event<\/code>.<\/p>\n<p>\u0414\u043b\u044f\u00a0\u0438\u043d\u0444\u043e\u0440\u043c\u0430\u0442\u0438\u0432\u043d\u043e\u0441\u0442\u0438 \u043d\u0430\u0448 \u043c\u0435\u0442\u043e\u0434 ProduceMessage \u0431\u0443\u0434\u0435\u0442 \u0432\u043e\u0437\u0432\u0440\u0430\u0449\u0430\u0442\u044c <code>offset<\/code> \u0437\u0430\u043f\u0438\u0441\u0430\u043d\u043d\u043e\u0433\u043e \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f \u0438 \u043e\u0448\u0438\u0431\u043a\u0443, \u0435\u0441\u043b\u0438 \u043e\u043d\u0430 \u0432\u043e\u0437\u043d\u0438\u043a\u043b\u0430.<\/p>\n<p>\u0412\u00a0\u043a\u0430\u0447\u0435\u0441\u0442\u0432\u0435 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f Protobuf \u0431\u0443\u0434\u0435\u043c \u043f\u0435\u0440\u0435\u0434\u0430\u0432\u0430\u0442\u044c \u0441\u043b\u0435\u0434\u0443\u044e\u0449\u0435\u0435 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 <a href=\"https:\/\/github.com\/PakshNina\/sr\/blob\/main\/proto\/test.v1.proto\"><u>test.v1.proto<\/u><\/a> \u0441\u043e \u0441\u0445\u0435\u043c\u043e\u0439:<\/p>\n<pre><code class=\"yaml\">syntax = \"proto3\"; option go_package = \".\/pkg\/test.v1\"; package test.v1;  message TestMessage {  int32 Value = 1; }<\/code><\/pre>\n<p>\u0412\u0430\u0436\u043d\u043e \u0443\u043a\u0430\u0437\u0430\u0442\u044c \u0434\u0438\u0440\u0435\u043a\u0442\u0438\u0432\u0443 package \u0432.proto \u0444\u0430\u0439\u043b\u0435, \u043e\u0441\u043e\u0431\u0435\u043d\u043d\u043e \u0432\u00a0\u0440\u0430\u0437\u0440\u0435\u0437\u0435 \u0440\u0430\u0431\u043e\u0442\u044b \u0441\u00a0\u043d\u0435\u0441\u043a\u043e\u043b\u044c\u043a\u0438\u043c\u0438 \u0432\u0435\u0440\u0441\u0438\u044f\u043c\u0438 \u043e\u0434\u043d\u043e\u0433\u043e \u043a\u043e\u043d\u0442\u0440\u0430\u043a\u0442\u0430. Go \u043d\u0435\u00a0c\u043a\u043e\u043c\u043f\u0438\u043b\u0438\u0440\u0443\u0435\u0442 \u043a\u043e\u0434, \u0435\u0441\u043b\u0438 \u0432\u00a0\u043e\u0434\u043d\u043e\u043c \u043f\u0430\u043a\u0435\u0442\u0435 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u0435\u0442\u0441\u044f \u0434\u0432\u0435 \u0432\u0435\u0440\u0441\u0438\u0438 \u043a\u043e\u043d\u0442\u0440\u0430\u043a\u0442\u043e\u0432 \u0441\u00a0\u043e\u0434\u0438\u043d\u0430\u043a\u043e\u0432\u044b\u043c\u0438 \u0438\u043b\u0438\u00a0\u043e\u0442\u0441\u0443\u0442\u0441\u0442\u0432\u0443\u044e\u0449\u0438\u043c package.<\/p>\n<p>\u0421\u0433\u0435\u043d\u0435\u0440\u0438\u0440\u043e\u0432\u0430\u0442\u044c \u0438\u0437.proto \u0444\u0430\u0439\u043b\u0430 go \u043a\u043e\u0434 \u043c\u043e\u0436\u043d\u043e \u0441\u00a0\u043f\u043e\u043c\u043e\u0449\u044c\u044e \u043a\u043e\u043c\u0430\u043d\u0434\u044b (\u043e\u043d \u0431\u0443\u0434\u0435\u0442 \u0441\u0433\u0435\u043d\u0435\u0440\u0438\u0440\u043e\u0432\u0430\u043d \u0432\u00a0\u043f\u0430\u043f\u043a\u0443 pkg\/test.v1):<\/p>\n<pre><code class=\"powershell\">protoc --go_out=. proto\/test.v1.proto<\/code><\/pre>\n<p>\u0414\u043b\u044f\u00a0\u0433\u0435\u043d\u0435\u0440\u0430\u0446\u0438\u0438 \u043a\u043e\u0434\u0430 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u0435\u0442\u0441\u044f \u0443\u0442\u0438\u043b\u0438\u0442\u0430 <a href=\"https:\/\/grpc.io\/docs\/protoc-installation\/\"><u>protoc<\/u><\/a>.<\/p>\n<p>\u0422\u0430\u043a\u0436\u0435 \u043e\u0431\u0440\u0430\u0442\u0438\u0442\u0435 \u0432\u043d\u0438\u043c\u0430\u043d\u0438\u0435, \u0447\u0442\u043e\u00a0\u0434\u043b\u044f\u00a0\u0433\u0435\u043d\u0435\u0440\u0430\u0446\u0438\u0438 \u043a\u043e\u0434\u0430 \u0432\u00a0go \u043d\u0435\u043e\u0431\u0445\u043e\u0434\u0438\u043c\u0430 \u043e\u043f\u0446\u0438\u044f go_package, \u043a\u043e\u0442\u043e\u0440\u0430\u044f \u043e\u043f\u0440\u0435\u0434\u0435\u043b\u044f\u0435\u0442 \u043f\u0443\u0442\u044c \u0438\u043c\u043f\u043e\u0440\u0442\u0430 \u043f\u0430\u043a\u0435\u0442\u0430 c \u0441\u0433\u0435\u043d\u0435\u0440\u0438\u0440\u043e\u0432\u0430\u043d\u043d\u044b\u043c \u043a\u043e\u0434\u043e\u043c.<\/p>\n<p>\u0415\u0441\u043b\u0438 \u0432\u00a0\u043a\u043e\u043d\u0442\u0440\u0430\u043a\u0442\u0435 \u043e\u043d\u0430 \u043e\u0442\u0441\u0443\u0442\u0441\u0442\u0432\u0443\u0435\u0442, \u043c\u043e\u0436\u043d\u043e \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u044c M \u0444\u043b\u0430\u0433 \u0434\u043b\u044f\u00a0\u0443\u043a\u0430\u0437\u0430\u043d\u0438\u044f \u043f\u0443\u0442\u0438 \u0438\u043c\u043f\u043e\u0440\u0442\u0430 \u043f\u0430\u043a\u0435\u0442\u0430 (\u0441\u0433\u0435\u043d\u0435\u0440\u0438\u0440\u043e\u0432\u0430\u043d\u043d\u044b\u0439 \u043a\u043e\u0434 \u0431\u0443\u0434\u0435\u0442 \u0442\u0430\u043a\u0436\u0435 \u043b\u0435\u0436\u0430\u0442\u044c \u0432\u00a0pkg\/test.v1):<\/p>\n<pre><code class=\"powershell\">protoc --go_out=. --proto_path=proto --go_opt=Mtest.v1.proto=.\/pkg\/test.v1 proto\/test.v1.proto<\/code><\/pre>\n<p>\u0421\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 TestMessage \u0431\u0443\u0434\u0435\u043c \u043e\u0442\u043f\u0440\u0430\u0432\u043b\u044f\u0442\u044c \u0432 \u0442\u043e\u043f\u0438\u043a \u2018topic.v1\u2019 Kafka. \u041f\u043e\u043b\u043d\u044b\u0439 \u043a\u043e\u0434 \u043f\u0440\u0438\u043c\u0435\u0440\u0430 \u0434\u043b\u044f \u0444\u0443\u043d\u043a\u0446\u0438\u0438 main <a href=\"https:\/\/github.com\/PakshNina\/sr\/blob\/main\/cmd\/producer\/main.go\"><u>\u0437\u0434\u0435\u0441\u044c<\/u><\/a>:<\/p>\n<pre><code class=\"go\">const (   topic = \"topic.v1\" )  func main() {   kafkaURL := os.Getenv(\"KAFKA_URL\")   schemaRegistryURL := os.Getenv(\"SCHEMA_REGISTRY_URL\")   producer, err := kafka.NewProducer(kafkaURL, schemaRegistryURL)   defer producer.Close()    if err != nil {      log.Fatalf(\"error with producer: %v\", err)   }   testMSG := test.TestMessage{Value: 42}   offset, err := producer.ProduceMessage(&amp;testMSG, topic)   if err != nil {      log.Fatalf(\"error with produce message: %v\", err)   }   fmt.Println(offset) }<\/code><\/pre>\n<p>\u0415\u0441\u043b\u0438 \u043c\u044b \u0437\u0430\u043f\u0443\u0441\u0442\u0438\u043c \u043a\u043e\u0434, \u043d\u0435\u00a0\u0437\u0430\u0431\u044b\u0432 \u0443\u043a\u0430\u0437\u0430\u0442\u044c \u0432\u00a0\u043f\u0435\u0440\u0435\u043c\u0435\u043d\u043d\u044b\u0445 \u043e\u043a\u0440\u0443\u0436\u0435\u043d\u0438\u044f <code>KafkaURL<\/code> \u0438 <code>SchemaRegistryURL<\/code> \u043f\u043e\u0434\u00a0\u0438\u043c\u0435\u043d\u0430\u043c\u0438 <code>KAFKA_URL<\/code> \u0438 <code>SCHEMA_REGISTRY_URL<\/code>, \u0442\u043e \u043c\u044b \u043f\u043e\u043b\u0443\u0447\u0438\u043c \u0438\u0437\u00a0Kafka \u0441\u0434\u0432\u0438\u0433 offset \u0434\u043b\u044f\u00a0\u043d\u0430\u0448\u0435\u0433\u043e \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u0440\u0430\u0432\u0435\u043d 0. \u0412\u0441\u0435 \u0440\u0430\u0431\u043e\u0442\u0430\u0435\u0442!<\/p>\n<p>\u041d\u043e\u00a0\u043f\u043e\u0433\u043e\u0434\u0438\u0442\u0435, \u0447\u0442\u043e\u00a0\u0437\u043d\u0430\u0447\u0438\u0442 \u0432\u0441\u0435 \u0440\u0430\u0431\u043e\u0442\u0430\u0435\u0442? \u0417\u0430\u0433\u0440\u0443\u0437\u0438\u043b\u0430\u0441\u044c\u00a0\u043b\u0438 \u0441\u0445\u0435\u043c\u0430? \u0427\u0442\u043e\u00a0\u0432\u043e\u043e\u0431\u0449\u0435 \u043f\u0440\u043e\u0438\u0437\u043e\u0448\u043b\u043e?<\/p>\n<p>\u0415\u0441\u043b\u0438 \u0432\u044b \u043f\u043e\u043c\u043d\u0438\u0442\u0435, SR \u043f\u0440\u0435\u0434\u043e\u0441\u0442\u0430\u0432\u043b\u044f\u0435\u0442 REST API \u0434\u043b\u044f\u00a0\u0440\u0430\u0431\u043e\u0442\u044b \u0441\u043e \u0441\u0445\u0435\u043c\u0430\u043c\u0438, \u043f\u043e\u044d\u0442\u043e\u043c\u0443, \u043c\u044b \u043c\u043e\u0436\u0435\u043c \u0441\u0434\u0435\u043b\u0430\u0442\u044c \u0437\u0430\u043f\u0440\u043e\u0441 \u043d\u0430\u00a0\u043f\u043e\u043b\u0443\u0447\u0435\u043d\u0438\u0435 \u0432\u0441\u0435\u0445 \u0441\u0443\u0449\u0435\u0441\u0442\u0432\u0443\u044e\u0449\u0438\u0445 \u0441\u0445\u0435\u043c (<code>{{schema-registry-url}}<\/code> \u00a0\u2014 \u0430\u0434\u0440\u0435\u0441 \u043d\u0430\u0448\u0435\u0433\u043e \u0441\u0435\u0440\u0432\u0435\u0440\u0430 SR):<\/p>\n<pre><code class=\"yaml\">GET {{schema-registry-url}}\/schemas\/<\/code><\/pre>\n<p>\u0412 \u043e\u0442\u0432\u0435\u0442 \u043c\u044b \u043f\u043e\u043b\u0443\u0447\u0438\u043c:<\/p>\n<pre><code class=\"yaml\">[   {        \"subject\": \"topic.v1-value\",        \"version\": 1,        \"id\": 1,        \"schemaType\": \"PROTOBUF\",        \"schema\": \"syntax = \\\"proto3\\\";\\npackage test.v1;\\n\\noption go_package = \\\".\/pkg\/test.v1\\\";\\n\\nmessage TestMessage {\\n  int32 Value = 1;\\n}\\n\"    } ]<\/code><\/pre>\n<p>\u0412\u00a0\u043f\u043e\u043b\u0435 schema \u043c\u044b \u0432\u0438\u0434\u0438\u043c \u0438\u0441\u0445\u043e\u0434\u043d\u044b\u0439 \u0444\u0430\u0439\u043b.proto \u0432\u00a0\u0442\u0435\u043a\u0441\u0442\u043e\u0432\u043e\u043c \u0432\u0438\u0434\u0435.<\/p>\n<p>\u041a\u0430\u043a\u00a0\u0441\u0445\u0435\u043c\u0430 \u043f\u043e\u043f\u0430\u043b\u0430 \u0432\u00a0SR, \u0435\u0441\u043b\u0438 \u043c\u044b \u043d\u0438\u0447\u0435\u0433\u043e \u0432\u0440\u0443\u0447\u043d\u0443\u044e \u043d\u0435\u00a0\u0441\u043e\u0437\u0434\u0430\u0432\u0430\u043b\u0438 \u0438 \u043d\u0435\u00a0\u0432\u044b\u0437\u044b\u0432\u0430\u043b\u0438 \u043d\u0438\u043a\u0430\u043a\u0438\u0445 POST?<\/p>\n<p>\u0414\u0435\u043b\u043e \u0432\u00a0\u0442\u043e\u043c, \u043f\u043e\u00a0\u0443\u043c\u043e\u043b\u0447\u0430\u043d\u0438\u044e \u0443\u00a0\u0441\u0435\u0440\u0438\u0430\u043b\u0438\u0437\u0430\u0442\u043e\u0440\u0430 SR \u0432\u043a\u043b\u044e\u0447\u0435\u043d\u0430 \u043e\u043f\u0446\u0438\u044f <code>AutoRegisterSchemas<\/code>, \u043a\u043e\u0442\u043e\u0440\u0430\u044f \u0430\u0432\u0442\u043e\u043c\u0430\u0442\u0438\u0447\u0435\u0441\u043a\u0438 \u0440\u0435\u0433\u0438\u0441\u0442\u0440\u0438\u0440\u0443\u0435\u0442 \u0441\u0445\u0435\u043c\u044b \u043f\u0440\u0438\u00a0\u0441\u0435\u0440\u0438\u0430\u043b\u0438\u0437\u0430\u0446\u0438\u0438 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439 (<a href=\"https:\/\/github.com\/confluentinc\/confluent-kafka-go\/blob\/master\/schemaregistry\/serde\/config.go#L31\">\u0438\u0441\u0445\u043e\u0434\u043d\u0438\u043a<\/a>).<\/p>\n<figure class=\"full-width\"><figcaption>\u0420\u0438\u0441 2. \u041a\u043e\u043d\u0444\u0438\u0433 \u0441\u0435\u0440\u0438\u0430\u043b\u0438\u0437\u0430\u0442\u043e\u0440\u0430 SR \u043f\u043e \u0443\u043c\u043e\u043b\u0447\u0430\u043d\u0438\u044e \u0432 schemaregistry\/serde\/config.go<\/figcaption><\/figure>\n<p>\u0421\u0445\u0435\u043c\u0430 \u0430\u0432\u0442\u043e\u043c\u0430\u0442\u0438\u0447\u0435\u0441\u043a\u0438 \u0440\u0435\u0433\u0438\u0441\u0442\u0440\u0438\u0440\u0443\u0435\u0442\u0441\u044f \u043f\u0440\u0438\u00a0\u0432\u044b\u0437\u043e\u0432\u0435 \u043c\u0435\u0442\u043e\u0434\u0430 <code>p.serializer.Serialize<\/code>, \u0438 \u0435\u0441\u043b\u0438 \u043e\u043d\u0430 \u043d\u0435\u00a0\u0441\u0443\u0449\u0435\u0441\u0442\u0432\u043e\u0432\u0430\u043b\u0430, \u0435\u0439 \u043f\u0440\u0438\u0441\u0432\u0430\u0438\u0432\u0430\u0435\u0442\u0441\u044f \u043d\u043e\u0432\u044b\u0439 id.<\/p>\n<p>\u0422\u0430\u043a \u043a\u0430\u043a\u00a0\u043c\u044b \u043e\u0442\u043f\u0440\u0430\u0432\u0438\u043b\u0438 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u0432\u00a0\u043f\u0435\u0440\u0432\u044b\u0439 \u0440\u0430\u0437, \u043d\u0430\u0448\u0430 \u0441\u0445\u0435\u043c\u0430 \u0430\u0432\u0442\u043e\u043c\u0430\u0442\u0438\u0447\u0435\u0441\u043a\u0438 \u0437\u0430\u0440\u0435\u0433\u0438\u0441\u0442\u0440\u0438\u0440\u043e\u0432\u0430\u043b\u0430\u0441\u044c \u0441\u00a0id = 1, version = 1\u00a0\u0438 \u0442\u0438\u043f\u043e\u043c PROTOBUF.<\/p>\n<p>\u0415\u0434\u0438\u043d\u0441\u0442\u0432\u0435\u043d\u043d\u043e\u0435, \u0447\u0442\u043e\u00a0\u0441\u0440\u0430\u0437\u0443 \u0432\u044b\u0437\u044b\u0432\u0430\u0435\u0442 \u0432\u043e\u043f\u0440\u043e\u0441\u00a0\u2014 \u044d\u0442\u043e \u043f\u043e\u043b\u0435 subject, \u0432\u00a0\u043a\u043e\u0442\u043e\u0440\u043e\u043c \u0437\u043d\u0430\u0447\u0435\u043d\u0438\u0435 <code>topic.v1-value<\/code>, \u043d\u0435\u0441\u043c\u043e\u0442\u0440\u044f \u043d\u0430\u00a0\u0442\u043e, \u0447\u0442\u043e\u00a0\u0432\u00a0\u0431\u0440\u043e\u043a\u0435\u0440\u0435 Kafka \u043c\u044b \u043d\u0430\u0437\u0432\u0430\u043b\u0438 \u0442\u043e\u043f\u0438\u043a <code>topic.v1<\/code>. \u041e\u0442\u043a\u0443\u0434\u0430 \u043f\u043e\u044f\u0432\u0438\u043b\u0441\u044f \u043f\u043e\u0441\u0442\u0444\u0438\u043a\u0441 <code>-value<\/code>?<\/p>\n<p>SR \u0440\u0435\u0433\u0438\u0441\u0442\u0440\u0438\u0440\u0443\u0435\u0442 \u0441\u0445\u0435\u043c\u0443 \u0432\u00a0\u0441\u0432\u043e\u0435\u043c \u0440\u0435\u0435\u0441\u0442\u0440\u0435 \u0432\u00a0\u043f\u0440\u043e\u0441\u0442\u0440\u0430\u043d\u0441\u0442\u0432\u0435 \u0438\u043c\u0435\u043d <code>subject<\/code>. \u0412\u00a0\u0440\u0430\u043c\u043a\u0430\u0445 \u043e\u0434\u043d\u043e\u0433\u043e \u043f\u0440\u043e\u0441\u0442\u0440\u0430\u043d\u0441\u0442\u0432\u0430 \u0438\u043c\u0435\u043d \u043f\u0440\u043e\u0438\u0437\u0432\u043e\u0434\u0438\u0442\u0441\u044f \u043f\u0440\u043e\u0432\u0435\u0440\u043a\u0430 \u043d\u0430\u00a0\u0441\u043e\u0432\u043c\u0435\u0441\u0442\u0438\u043c\u043e\u0441\u0442\u044c \u0441\u0445\u0435\u043c. \u0412\u0441\u0435 \u0432\u0435\u0440\u0441\u0438\u0438 \u0441\u0445\u0435\u043c\u044b \u043f\u0440\u0438\u0432\u044f\u0437\u0430\u043d\u044b <\/p>\n<\/div>\n<\/div>\n<\/div>\n<\/div>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[],"tags":[],"class_list":["post-396864","post","type-post","status-publish","format-standard","hentry"],"_links":{"self":[{"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/posts\/396864","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=396864"}],"version-history":[{"count":0,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/posts\/396864\/revisions"}],"wp:attachment":[{"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=396864"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=396864"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=396864"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}