spec/rdkafka/config_spec.rb in karafka-rdkafka-0.13.8 vs spec/rdkafka/config_spec.rb in karafka-rdkafka-0.13.9

- old
+ new

@@ -1,9 +1,7 @@ # frozen_string_literal: true -require "spec_helper" - describe Rdkafka::Config do context "logger" do it "should have a default logger" do expect(Rdkafka::Config.logger).to be_a Logger end @@ -109,9 +107,17 @@ expect(config[:"api.version.request"]).to eq true end it "should create a consumer with valid config" do consumer = rdkafka_consumer_config.consumer + expect(consumer).to be_a Rdkafka::Consumer + consumer.close + end + + it "should create a consumer with consumer_poll_set set to false" do + config = rdkafka_consumer_config + config.consumer_poll_set = false + consumer = config.consumer expect(consumer).to be_a Rdkafka::Consumer consumer.close end it "should raise an error when creating a consumer with invalid config" do