Commit e81f784

committed

Style fixes

1 parent dedb02a commit e81f784Copy full SHA for e81f784

File tree

+11

-7

lines changed

+11

-7

lines changed

Lines changed: 5 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -60,11 +60,14 @@ def update_conf_group_protocol(conf=None):`
`60`	`60`
`61`	`61`	`@staticmethod`
`62`	`62`	`def can_upgrade_group_protocol_to_consumer(conf):`
`63`		`- return conf is not None and 'group.id' in conf and 'group.protocol' not in conf and TestUtils.use_group_protocol_consumer()`
	`63`	`+ return (conf is not None and 'group.id' in conf and`
	`64`	`+ 'group.protocol' not in conf and TestUtils.use_group_protocol_consumer())`
`64`	`65`
`65`	`66`	`@staticmethod`
`66`	`67`	`def remove_forbidden_conf_group_protocol_consumer(conf):`
`67`		`- if conf is None or not TestUtils.use_group_protocol_consumer() or conf.get('group.protocol', 'consumer') != 'consumer':`
	`68`	`+ if (conf is None or`
	`69`	`+ not TestUtils.use_group_protocol_consumer() or`
	`70`	`+ conf.get('group.protocol', 'consumer') != 'consumer'):`
`68`	`71`	`return`
`69`	`72`	`forbidden_conf_properties = ["session.timeout.ms",`
`70`	`73`	`"partition.assignment.strategy",`

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -233,7 +233,7 @@ def create_topic(self, prefix, conf=None, **create_topic_kwargs):`
`233`	`233`
`234`	`234`	`future_topic.get(name).result()`
`235`	`235`	`return name`
`236`		`-`
	`236`	`+`
`237`	`237`	`def delete_topic(self, topic):`
`238`	`238`	`"""`
`239`	`239`	`Deletes a topic with this cluster.`

Lines changed: 5 additions & 4 deletions

Original file line number	Diff line number	Diff line change
`@@ -73,15 +73,16 @@ class Operation(Enum):`
`73`	`73`	`REMOVE = 1`
`74`	`74`
`75`	`75`
`76`		`-def perform_consumer_upgrade_downgrade_test_with_partition_assignment_strategy(kafka_cluster, partition_assignment_strategy):`
	`76`	`+def perform_consumer_upgrade_downgrade_test_with_partition_assignment_strategy(`
	`77`	`+ kafka_cluster, partition_assignment_strategy):`
`77`	`78`	`"""`
`78`	`79`	`Test consumer upgrade and downgrade.`
`79`	`80`	`"""`
`80`	`81`	`topic_name_prefix = f"{topic_prefix}_{partition_assignment_strategy}"`
`81`	`82`	`topic = kafka_cluster.create_topic_and_wait_propogation(topic_name_prefix,`
`82`		`- {`
`83`		`- "num_partitions": number_of_partitions`
`84`		`- })`
	`83`	`+ {`
	`84`	`+ "num_partitions": number_of_partitions`
	`85`	`+ })`
`85`	`86`	`admin_client = kafka_cluster.admin()`
`86`	`87`
`87`	`88`	`consumer_conf = {'group.id': topic,`

Comments

(0)