lib/avromatic.rb in avromatic-3.0.2 vs lib/avromatic.rb in avromatic-4.0.0
- old
+ new
@@ -32,10 +32,11 @@
eager_load_models!
end
def self.build_schema_registry
raise 'Avromatic must be configured with a registry_url' unless registry_url
+
if use_schema_fingerprint_lookup
AvroSchemaRegistry::CachedClient.new(
AvroSchemaRegistry::Client.new(registry_url, logger: logger)
)
else
@@ -49,9 +50,10 @@
self.schema_registry = build_schema_registry
end
def self.build_messaging
raise 'Avromatic must be configured with a schema_store' unless schema_store
+
Avromatic::Messaging.new(
registry: schema_registry || build_schema_registry,
schema_store: schema_store,
logger: logger
)