From 3964f2aae25d7f43d392a2ca688a6e71cecbc301 Mon Sep 17 00:00:00 2001
From: Joe Keen <joe.keen@hp.com>
Date: Mon, 9 Nov 2015 10:50:20 -0700
Subject: [PATCH] Adapting persister because of changes to monasca common

Change-Id: I1a10e26340dcbd4dd634b32a52f554d073bfb946
---
 monasca_persister/persister.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/monasca_persister/persister.py b/monasca_persister/persister.py
index 403617ee..7e6b905c 100644
--- a/monasca_persister/persister.py
+++ b/monasca_persister/persister.py
@@ -179,8 +179,8 @@ class AbstractPersister(threading.Thread):
                                        kafka_conf.group_id,
                                        kafka_conf.topic,
                                        repartition_callback=self._flush,
-                                       periodic_callback=self._flush,
-                                       periodic_callback_rate=kafka_conf.max_wait_time_seconds)
+                                       commit_callback=self._flush,
+                                       commit_timeout=kafka_conf.max_wait_time_seconds)
 
         self._influxdb_client = InfluxDBClient(influxdb_conf.ip_address,
                                                influxdb_conf.port,