diff --git a/monasca_persister/conf/kafka_alarm_history.py b/monasca_persister/conf/kafka_alarm_history.py
index 51ce9845..87ea58ff 100644
--- a/monasca_persister/conf/kafka_alarm_history.py
+++ b/monasca_persister/conf/kafka_alarm_history.py
@@ -24,6 +24,9 @@ from monasca_persister.conf import types
 kafka_alarm_history_group = cfg.OptGroup(name='kafka_alarm_history',
                                          title='kafka_alarm_history')
 kafka_alarm_history_opts = [
+    cfg.BoolOpt('enabled',
+                help='Enable alarm state history persister',
+                default=True),
     # NOTE(czarneckia) default by reference does not work with ListOpt
     cfg.ListOpt('uri',
                 help='Comma separated list of Kafka broker host:port',
diff --git a/monasca_persister/conf/kafka_events.py b/monasca_persister/conf/kafka_events.py
index cec049e4..b9e4e48a 100644
--- a/monasca_persister/conf/kafka_events.py
+++ b/monasca_persister/conf/kafka_events.py
@@ -23,6 +23,9 @@ from monasca_persister.conf import types
 kafka_events_group = cfg.OptGroup(name='kafka_events',
                                   title='kafka_events')
 kafka_events_opts = [
+    cfg.BoolOpt('enabled',
+                help='Enable event persister',
+                default=False),
     cfg.ListOpt('uri',
                 help='Comma separated list of Kafka broker host:port',
                 default=['127.0.0.1:9092'],
diff --git a/monasca_persister/conf/kafka_metrics.py b/monasca_persister/conf/kafka_metrics.py
index df900445..70c8f8f1 100644
--- a/monasca_persister/conf/kafka_metrics.py
+++ b/monasca_persister/conf/kafka_metrics.py
@@ -24,6 +24,9 @@ from monasca_persister.conf import types
 kafka_metrics_group = cfg.OptGroup(name='kafka_metrics',
                                    title='kafka_metrics')
 kafka_metrics_opts = [
+    cfg.BoolOpt('enabled',
+                help='Enable metrics persister',
+                default=True),
     # NOTE(czarneckia) default by reference does not work with ListOpt
     cfg.ListOpt('uri',
                 help='Comma separated list of Kafka broker host:port',
diff --git a/monasca_persister/persister.py b/monasca_persister/persister.py
index 63448909..36bc9532 100644
--- a/monasca_persister/persister.py
+++ b/monasca_persister/persister.py
@@ -108,11 +108,17 @@ def main():
     config.parse_args()
 
     # Add processors for metrics topic
-    prepare_processes(cfg.CONF.kafka_metrics, cfg.CONF.repositories.metrics_driver)
+    if cfg.CONF.kafka_metrics.enabled:
+        prepare_processes(cfg.CONF.kafka_metrics,
+                          cfg.CONF.repositories.metrics_driver)
     # Add processors for alarm history topic
-    prepare_processes(cfg.CONF.kafka_alarm_history, cfg.CONF.repositories.alarm_state_history_driver)
+    if cfg.CONF.kafka_alarm_history.enabled:
+        prepare_processes(cfg.CONF.kafka_alarm_history,
+                          cfg.CONF.repositories.alarm_state_history_driver)
     # Add processors for events topic
-    prepare_processes(cfg.CONF.kafka_events, cfg.CONF.repositories.events_driver)
+    if cfg.CONF.kafka_events.enabled:
+        prepare_processes(cfg.CONF.kafka_events,
+                          cfg.CONF.repositories.events_driver)
 
     # Start
     try: