why controller must present in cluster ?

[yorkhellen]

hi all: I got a key error exception when using pykafka KeyError: 'Controller ID 200 not present in cluster' and I read the cluster.py https://github.com/Parsely/pykafka/blob/master/pykafka/cluster.py I don't know why controller must present in cluster , anyone can help. thx

[emmettbutler]

Thanks for the report, @yorkhellen. Can you post some code that generates this issue when you run it? It's not clear from your post how this is being triggered.

[yorkhellen]

I got the stack information i just new a kafka producer to send my app log message. and i read the https://github.com/Parsely/pykafka/blob/master/pykafka/cluster.py it will throw exception if the controller broker not in the self._brokers。