Sha256: b25ebec769c3c3cbe12c445a564f207ffc7ab39eae96d3bc7f7cc1899e3c4030
Contents?: true
Size: 1.01 KB
Versions: 20
Compression:
Stored size: 1.01 KB
Contents
# frozen_string_literal: true
require_relative 'avro_base'
require 'avro_turf/messaging'
module Deimos
module SchemaBackends
# Encode / decode using the Avro schema registry.
class AvroSchemaRegistry < AvroBase
# @override
def decode_payload(payload, schema:)
avro_turf_messaging.decode(payload.to_s, schema_name: schema)
end
# @override
def encode_payload(payload, schema: nil, topic: nil)
avro_turf_messaging.encode(payload, schema_name: schema, subject: topic || schema)
end
private
# @return [AvroTurf::Messaging]
def avro_turf_messaging
@avro_turf_messaging ||= AvroTurf::Messaging.new(
schema_store: @schema_store,
registry_url: Deimos.config.schema.registry_url,
schemas_path: Deimos.config.schema.path,
user: Deimos.config.schema.user,
password: Deimos.config.schema.password,
namespace: @namespace,
logger: Karafka.logger
)
end
end
end
end
Version data entries
20 entries across 20 versions & 1 rubygems