Merge pull request #1 from akashvacher/demote

Fixed flake8 errors for kafka/tools/assigner/actions/demote.py
linkedin · Jul 9, 2018 · de804a3 · de804a3
2 parents fe7e188 + 0057090
commit de804a3
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/kafka/tools/assigner/actions/demote.py b/kafka/tools/assigner/actions/demote.py
@@ -31,9 +31,8 @@ def __init__(self, args, cluster):
     def _add_args(cls, parser):
         parser.add_argument(
             '-b', '--brokers', type=int, help='List of broker ids to demote', required=True, nargs='*')
-        parser.add_argument('-t', '--topics', required=False, nargs='*', help=\
-            'Optional list of topics to use. If not specified, leadership of all topics lead by the brokers to ' \
-            'demote will be changed.')
+        parser.add_argument('-t', '--topics', required=False, nargs='*',
+                            help='Optional list of topics to use. If not specified, leadership of all topics lead by the brokers to demote will be changed.')
 
     def process_cluster(self):
         brokers_to_demote = set(self.args.brokers)