WIP for Kafka Manager

dazza-codes · Sep 25, 2017 · c3e5751 · c3e5751
1 parent 047f1b7
commit c3e5751
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/lib/kafka_manager/kafka_manager_service.rake b/lib/kafka_manager/kafka_manager_service.rake
@@ -14,6 +14,7 @@ namespace :kafka_manager do
         if kafka_manager_running?
           puts "#{host.hostname} is already running Kafka Manager"
         else
+          # TODO: does it need to be run by sudo?
           sudo('kafka-manager')
         end
       end
@@ -34,7 +35,8 @@ namespace :kafka_manager do
     task :stop do
       on roles(:kafka_manager) do
         # Ignore the exit(1) status when it's not running already
-        sudo('${KAFKA_BIN}/kafka-server-stop.sh || true')
+        # sudo('${KAFKA_BIN}/kafka-server-stop.sh || true')
+        puts 'TODO'
       end
     end
   end