spec/backends/kafka_async_spec.rb in deimos-ruby-1.24.2 vs spec/backends/kafka_async_spec.rb in deimos-ruby-2.0.0.pre.alpha1

@@ -1,11 +1,9 @@
 # frozen_string_literal: true
 
 RSpec.describe Deimos::Backends::KafkaAsync do
   include_context 'with publish_backend'
   it 'should publish to Kafka asynchronously' do
-    producer = instance_double(Phobos::Producer::ClassMethods::PublicAPI)
-    expect(producer).to receive(:async_publish_list).with(messages.map(&:encoded_hash))
-    expect(described_class).to receive(:producer).and_return(producer)
+    expect(Karafka.producer).to receive(:produce_many_async).with(messages)
     described_class.publish(producer_class: MyProducer, messages: messages)
   end
 end