spec/inputs/kafka_spec.rb in logstash-input-kafka-2.0.3 vs spec/inputs/kafka_spec.rb in logstash-input-kafka-2.0.4

@@ -40,10 +40,10 @@
   def run(a_num_threads, a_queue)
     blah = TestMessageAndMetadata.new(@topic, 0, nil, 'Kafka message')
     Thread.new do
       while true
         a_queue << blah
-        sleep 0.2
+        sleep 10
       end
     end
   end
 end