Merge "Fix invalid log message"

This commit is contained in:
Jenkins 2017-04-18 10:52:45 +00:00 committed by Gerrit Code Review
commit 4facddc0df
1 changed files with 1 additions and 1 deletions

View File

@ -75,7 +75,7 @@ class Kafka(Plugin):
'but neither %s nor %s '
'executable was found.'),
_KAFKA_CONSUMER_GROUP_COMMAND,
_KAFKA_CONSUMER_GROUP_COMMAND)
_KAFKA_ZOOKEEPER_SHELL_COMMAND)
def _detect_consumers(self):
"""Using zookeeper and a kafka connection find the consumers and associated topics. """