config spec

karafka · Nov 6, 2023 · 5f9112a · 5f9112a
1 parent a55b3d3
commit 5f9112a
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/spec/rdkafka/config_spec.rb b/spec/rdkafka/config_spec.rb
@@ -113,6 +113,14 @@ def call(stats); end
       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
       config = Rdkafka::Config.new('invalid.key' => 'value')
       expect {