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