lib/wukong-load/loaders/kafka.rb in wukong-load-0.1.0 vs lib/wukong-load/loaders/kafka.rb in wukong-load-0.1.1

@@ -46,10 +46,10 @@
 
       # Creates the producer.
       def setup
         begin
           require 'kafka'
-        rescue => e
+        rescue LoadError => e
           raise Error.new("Please ensure that the 'kafka-rb' gem is installed and available (in your Gemfile)")
         end
         log.debug("Connecting to Kafka broker at #{host}:#{port}...")
         begin
           self.producer = Kafka::MultiProducer.new(:host => host, :port => port)