MissingClientError on manual offset commit with rspec about karafka-testing HOT 6 CLOSED

require_relative '../../karafka_app'

RSpec.describe RuleNotificationsConsumer, vcr: true do
  # This will create a consumer instance with all the settings defined for the given topic
  subject(:consumer) { karafka_consumer_for(:scheduled_rule_events) }

  let(:app) { create(:app) }
  let(:rule1_no_log) { create(:butler_rule, app: app) }
  let(:rule2) { create(:butler_rule, :manual, app: app) }
  let!(:log_rule_2) { create(:butler_rule_log, rule: rule2) }
  let(:rule3) { create(:butler_rule, :manual, app: app) }
  let!(:log_rule_3) { create(:butler_rule_log, rule: rule3) }

  before do
    # Sends messages to Karafka consumer
    publish_for_karafka(encode(rule1_no_log.id, 'opened'))
    publish_for_karafka(encode(rule2.id, 'opened'))
    publish_for_karafka(encode(rule2.id, 'opened'))
    publish_for_karafka(encode(rule2.id, 'errored'))
    publish_for_karafka(encode(rule3.id, 'errored'))
    publish_for_karafka(encode('nonexistent_id', 'errored'))
  end

  def avro
    @avro ||= AvroRegistry.instance
  end

  def encode(rule_id, type)
    avro.encode({
                  'rule_id' => rule_id,
                  'type' => type,
                  'timestamp' => Time.now
                }, subject: 'scheduled_rule_event', version: 1)
  end

  it 'expects to log a proper message' do
    consumer.consume
    expect(log_rule_2.reload.opened_count).to eq 2
    expect(log_rule_2.errored_count).to eq 1
    expect(log_rule_3.reload.opened_count).to eq 0
    expect(log_rule_3.errored_count).to eq 1
  end
end