Commit c9bb8475 authored by Patrick Godwin's avatar Patrick Godwin
Browse files

aggregator.py, kafka.py: fix typo in kafka.Client method name, remove unused tag opt

parent 6811064d
Pipeline #133559 passed with stages
in 2 minutes and 42 seconds
......@@ -68,8 +68,6 @@ def _add_parser_args(parser):
help="specify Kafka URI to read metrics from. default = kafka://localhost:9092.")
parser.add_argument('-t', '--topic', action='append',
help="Specify topic to aggregate from. Can be given multiple times.")
parser.add_argument('--tag', default='generic',
help = "Specify a tag for this aggregator job. default = 'generic'.")
parser.add_argument('--across-jobs', action = 'store_true',
help = "If set, aggregate data across jobs as well.")
parser.add_argument('--processing-cadence', default = 0.5,
......
......@@ -98,7 +98,7 @@ class Client(object):
msg.timestamp()[0],
)
def store(self, topic, data, tags=None):
def write(self, topic, data, tags=None):
"""Stores data into Kafka.
Parameters
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment