Merge "Change default for [kafka]num_processors to 1"

monasca_persister/conf/kafka_common.py

@@ -42,7 +42,7 @@ kafka_common_opts = [
                default=32768),
     cfg.IntOpt('num_processors',
                help='Number of processes spawned by persister',
-               default=0)
+               default=1)
 ]
 
 kafka_common_group = cfg.OptGroup(name='kafka',

monasca_persister/persister.py

@@ -102,6 +102,10 @@ def prepare_processes(conf, repo_driver):
         for proc in range(0, conf.num_processors):
             processors.append(multiprocessing.Process(
                 target=start_process, args=(repository, conf)))
+    else:
+        LOG.warning("Number of processors (num_processors) is {}".format(
+            conf.num_processors))
+
 
 def main():
     """Start persister."""