Schema Registry в Kafka. Зачем в Go?

Ответ

Schema Registry хранит схемы сообщений (Avro, JSON Schema, Protobuf); версионирование и совместимость. Продюсер и консьюмер получают/проверяют схему по id в заголовке сообщения. В Go используют клиент Schema Registry (confluentinc/confluent-kafka-go с schema_registry) для сериализации/десериализации. Удобно при эволюции формата и нескольких сервисах на разных языках.

sr, _ := schemaregistry.NewClient(schemaregistry.NewConfig("http://localhost:8081"))
encoder, _ := avro.NewGenericAvroSerializer(sr, ...)
payload, _ := encoder.Serialize("topic", msg)