Traceback (most recent call last):


 "C:\Users\adnan\AppData\Local\Programs\Python\Python38-32\lib\site-packages\tornado\ioloop.py", line 907, in _run

return self.callback()


 "C:\Users\adnan\AppData\Local\Programs\Python\Python38-32\lib\site-packages\distributed\nanny.py", line 414, in memory_monitor

process = self.process.process
AttributeError: 'NoneType' object has no attribute 'process'

Traceback (most recent call last):


 "/home/ny30180a/workspace/python/kafkatest/kafkatest.py", line 23, in <module>

for message in consumer:


 "/opt/continuum/anaconda3/lib/python3.6/site-packages/kafka/consumer/group.py", line 1095, in __next__

return next(self._iterator)


 "/opt/continuum/anaconda3/lib/python3.6/site-packages/kafka/consumer/group.py", line 1018, in _message_generator

self._coordinator.ensure_coordinator_ready()


 "/opt/continuum/anaconda3/lib/python3.6/site-packages/kafka/coordinator/base.py", line 216, in ensure_coordinator_ready

if future.failed():
AttributeError: 'NoneType' object has no attribute 'failed'
