Sha256: 33985f80e070152a85b214d69a0dbcb6d722d9ff0aca48851dfc597f6fbb0d12
Contents?: true
Size: 470 Bytes
Versions: 20
Compression:
Stored size: 470 Bytes
Contents
# frozen_string_literal: true
module Deimos
module Backends
# Backend which produces to Kafka via an async producer.
class KafkaAsync < Base
# :nodoc:
def self.execute(producer_class:, messages:)
Karafka.producer.produce_many_async(messages)
Deimos.config.metrics&.increment(
'publish',
tags: %W(status:success topic:#{messages.first[:topic]}),
by: messages.size
)
end
end
end
end
Version data entries
20 entries across 20 versions & 1 rubygems