Contents

# frozen_string_literal: true

class FakeWaterDropClient
  def produce_sync(*)
    # no op
  end

  def produce_async(*)
    # no op
  end
end

Sbmt::KafkaProducer::KafkaClientFactory.singleton_class.prepend(
  Module.new do
    def default_client
      @default_client ||= FakeWaterDropClient.new
    end

    def build(*)
      @default_client ||= FakeWaterDropClient.new
    end
  end
)

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
sbmt-kafka_producer-3.0.0	lib/sbmt/kafka_producer/testing/configure_producer_client.rb
sbmt-kafka_producer-2.2.3	lib/sbmt/kafka_producer/testing/configure_producer_client.rb