fix the partitions data type error
the newer version of kafka client assumes that the partitions are a list of integers. This was not the case in earlier kafka client Change-Id: Icb706dd58816e60a047adc079cef425ac5696d6a
This commit is contained in:
parent
0f9b0e8e57
commit
15d8569019
|
@ -78,7 +78,7 @@ class KafkaConnection(object):
|
|||
self.max_retry = cfg.CONF.kafka_opts.max_retry
|
||||
self.auto_commit = cfg.CONF.kafka_opts.auto_commit
|
||||
self.compact = cfg.CONF.kafka_opts.compact
|
||||
self.partitions = cfg.CONF.kafka_opts.partitions
|
||||
self.partitions = [int(x) for x in cfg.CONF.kafka_opts.partitions]
|
||||
self.drop_data = cfg.CONF.kafka_opts.drop_data
|
||||
|
||||
self._client = None
|
||||
|
|
Loading…
Reference in New Issue