root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 3 Packages Projects Releases Wiki Activity

MINOR: Split at first occurrence of '=' in kafka.py props parsing (#5549) (#7042) 

This is a fix to #5226 to account for config properties that have an
equal char in the value.   Otherwise if there is one
equal char in the value the following error occurs:

dictionary update sequence element #XX has length 3; 2 is required

Reviewers: Colin Patrick McCabe <colin@cmccabe.xyz>, Ismael Juma <ismael@juma.me.uk>
This commit is contained in:
Konstantine Karantasis 2019-07-08 23:34:47 +02:00 committed by Colin Patrick McCabe
parent c0c51808af
commit ce1d3cd644
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
tests/kafkatest/services/kafka/kafka.py
View File

@ -221,7 +221,7 @@ class KafkaService(KafkaPathResolverMixin, JmxMixin, Service):
config_template = self.render('kafka.properties', node=node, broker_id=self.idx(node), config_template = self.render('kafka.properties', node=node, broker_id=self.idx(node),
security_config=self.security_config, num_nodes=self.num_nodes) security_config=self.security_config, num_nodes=self.num_nodes)
configs = dict( l.rstrip().split('=') for l in config_template.split('\n') configs = dict( l.rstrip().split('=', 1) for l in config_template.split('\n')
if not l.startswith("#") and "=" in l ) if not l.startswith("#") and "=" in l )
#load specific test override configs #load specific test override configs