diff --git a/monasca_persister/conf/kafka_common.py b/monasca_persister/conf/kafka_common.py index 534d5926..1217b075 100644 --- a/monasca_persister/conf/kafka_common.py +++ b/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', diff --git a/monasca_persister/persister.py b/monasca_persister/persister.py index c7bfd0c3..637abbaf 100644 --- a/monasca_persister/persister.py +++ b/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."""