lib/racecar/ctl.rb in racecar-0.2.1 vs lib/racecar/ctl.rb in racecar-0.3.0.beta1
- old
+ new
@@ -1,7 +1,7 @@
require "optparse"
-require "racecar/config_loader"
+require "racecar/rails_config_file_loader"
module Racecar
class Ctl
ProduceMessage = Struct.new(:value, :key, :topic)
@@ -44,10 +44,10 @@
if message.value.nil?
raise Racecar::Error, "no message value specified"
end
- ConfigLoader.load!
+ RailsConfigFileLoader.load!
Racecar.config.validate!
kafka = Kafka.new(
client_id: Racecar.config.client_id,