Fix flake8 warnings

Author: edenhill

confluent_kafka/kafkatest/verifiable_client.py

@@ -75,22 +75,24 @@ def set_config(conf, args):
                 # App config, skip
                 continue
 
-            n = n[5:] # Remove conf_ prefix
+            # Remove conf_ prefix
+            n = n[5:]
 
+            # Handle known Java properties to librdkafka properties.
             if n == 'partition.assignment.strategy':
                 # Convert Java class name to config value.
                 # "org.apache.kafka.clients.consumer.RangeAssignor" -> "range"
                 conf[n] = re.sub(r'org.apache.kafka.clients.consumer.(\w+)Assignor',
                                  lambda x: x.group(1).lower(), v)
-                                # Handle known Java properties to librdkafka properties.
+
             elif n == 'enable.idempotence':
                 # Ignore idempotence for now, best-effortly.
                 sys.stderr.write('%% WARN: Ignoring unsupported %s=%s\n' % (n, v))
             else:
                 conf[n] = v
 
     @staticmethod
-    def read_config_file (path):
+    def read_config_file(path):
         """Read (java client) config file and return dict with properties"""
         conf = {}