Merge pull request #2 from mokhan/kafkamain

Kafka

3 files changed, 9 insertions, 2 deletions

diff --git a/exe/killjoy b/exe/killjoy
index c22e9e9..902bdb0 100755
--- a/exe/killjoy
+++ b/exe/killjoy
@@ -12,7 +12,7 @@ server = ServerEngine::Daemon.new(Killjoy::Server, Killjoy::Worker, {}) do
     pid_path: 'tmp/killjoy.pid',
     queue_shards: configuration.shards,
     worker_type: 'process',
-    workers: configuration.shards,
+    workers: 1, # configuration.shards,
   }
 end
 server.run
diff --git a/exe/killjoy-publisher b/exe/killjoy-publisher
index 3d50a56..a969835 100755
--- a/exe/killjoy-publisher
+++ b/exe/killjoy-publisher
@@ -7,7 +7,8 @@ require "killjoy"
 log_file = ENV.fetch("LOG_FILE", "spec/fixtures/nginx.log")
 parser = Killjoy::LogParser.new
 
-message_bus = Killjoy::MessageBus.new
+#message_bus = Killjoy::MessageBus.new
+message_bus = Killjoy::Kafka::MessageBus.new
 Killjoy::Publisher.using(message_bus) do |publisher|
   log_file = File.join(Dir.pwd, log_file)
   lines = File.readlines(log_file)
diff --git a/exe/killjoy-timing b/exe/killjoy-timing
index bb48b60..6764710 100755
--- a/exe/killjoy-timing
+++ b/exe/killjoy-timing
@@ -25,6 +25,12 @@ Benchmark.ips do |x|
   x.report("mongo: writes") do
     experiments.mongo_writes
   end
+  x.report("kafka-mongo: writes") do
+    experiments.kafka_mongo_writes
+  end
+  x.report("kafka-cassandra: non blocking writes") do
+    experiments.kafka_cassandra_non_blocking_writes
+  end
 
   x.compare!
 end