openstack/monasca-persister
Code Issues Proposed changes

Adapting persister because of changes to monasca common

Browse Source 
Change-Id: I1a10e26340dcbd4dd634b32a52f554d073bfb946
This commit is contained in:
Joe Keen 2015-11-09 10:50:20 -07:00
parent b2479ae244
commit 3964f2aae2
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
monasca_persister/persister.py
View File

@ -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,