Contents

# frozen_string_literal: true

class FakeWaterDropClient
  Report = Struct.new(:topic_name, :partition, :offset)

  def produce_sync(*)
    Report.new("fake_topic", 0, 0)
  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

5 entries across 5 versions & 1 rubygems

Version	Path
sbmt-kafka_producer-3.2.2	lib/sbmt/kafka_producer/testing/configure_producer_client.rb
sbmt-kafka_producer-3.2.1	lib/sbmt/kafka_producer/testing/configure_producer_client.rb
sbmt-kafka_producer-3.2.0	lib/sbmt/kafka_producer/testing/configure_producer_client.rb
sbmt-kafka_producer-3.1.1	lib/sbmt/kafka_producer/testing/configure_producer_client.rb
sbmt-kafka_producer-3.1.0	lib/sbmt/kafka_producer/testing/configure_producer_client.rb