faust
faust copied to clipboard
ModuleNotFoundError
HI. I have got a error like this.
Command raised exception: ModuleNotFoundError("'kafka' is not a valid name. Did you mean one of aiokafka, kafka?") Maybe It has something to do with kafka library. Can I know why this is happening? Thanks.
Command raised exception: ModuleNotFoundError("'kafka' is not a valid name. Did you mean one of aiokafka, kafka?")
File "C:\Users\user\AppData\Local\Programs\Python\Python37\lib\site-packages\mode\worker.py", line 67, in exiting
yield
File "C:\Users\user\AppData\Local\Programs\Python\Python37\lib\site-packages\faust\cli\base.py", line 529, in _inner
cmd()
File "C:\Users\user\AppData\Local\Programs\Python\Python37\lib\site-packages\faust\cli\base.py", line 612, in __call__
self.run_using_worker(*args, **kwargs)
File "C:\Users\user\AppData\Local\Programs\Python\Python37\lib\site-packages\faust\cli\base.py", line 621, in run_using_worker
self.on_worker_created(worker)
File "C:\Users\user\AppData\Local\Programs\Python\Python37\lib\site-packages\faust\cli\worker.py", line 56, in on_worker_created
self.say(self.banner(worker))
File "C:\Users\user\AppData\Local\Programs\Python\Python37\lib\site-packages\faust\cli\worker.py", line 123, in banner
(' transport', app.transport.driver_version),
File "C:\Users\user\AppData\Local\Programs\Python\Python37\lib\site-packages\faust\app\base.py", line 1829, in transport
self._transport = self._new_transport()
File "C:\Users\user\AppData\Local\Programs\Python\Python37\lib\site-packages\faust\app\base.py", line 1685, in _new_transport
return transport.by_url(self.conf.broker_consumer[0])(
File "C:\Users\user\AppData\Local\Programs\Python\Python37\lib\site-packages\mode\utils\imports.py", line 101, in by_url
return self.by_name(URL(url).scheme)
File "C:\Users\user\AppData\Local\Programs\Python\Python37\lib\site-packages\mode\utils\imports.py", line 115, in by_name
f'{name!r} is not a valid name. {alt}') from exc
HI. I have got a error like this.
Command raised exception: ModuleNotFoundError("'kafka' is not a valid name. Did you mean one of aiokafka, kafka?") Maybe It has something to do with kafka library. Can I know why this is happening? Thanks.
Command raised exception: ModuleNotFoundError("'kafka' is not a valid name. Did you mean one of aiokafka, kafka?") File "C:\Users\user\AppData\Local\Programs\Python\Python37\lib\site-packages\mode\worker.py", line 67, in exiting yield File "C:\Users\user\AppData\Local\Programs\Python\Python37\lib\site-packages\faust\cli\base.py", line 529, in _inner cmd() File "C:\Users\user\AppData\Local\Programs\Python\Python37\lib\site-packages\faust\cli\base.py", line 612, in __call__ self.run_using_worker(*args, **kwargs) File "C:\Users\user\AppData\Local\Programs\Python\Python37\lib\site-packages\faust\cli\base.py", line 621, in run_using_worker self.on_worker_created(worker) File "C:\Users\user\AppData\Local\Programs\Python\Python37\lib\site-packages\faust\cli\worker.py", line 56, in on_worker_created self.say(self.banner(worker)) File "C:\Users\user\AppData\Local\Programs\Python\Python37\lib\site-packages\faust\cli\worker.py", line 123, in banner (' transport', app.transport.driver_version), File "C:\Users\user\AppData\Local\Programs\Python\Python37\lib\site-packages\faust\app\base.py", line 1829, in transport self._transport = self._new_transport() File "C:\Users\user\AppData\Local\Programs\Python\Python37\lib\site-packages\faust\app\base.py", line 1685, in _new_transport return transport.by_url(self.conf.broker_consumer[0])( File "C:\Users\user\AppData\Local\Programs\Python\Python37\lib\site-packages\mode\utils\imports.py", line 101, in by_url return self.by_name(URL(url).scheme) File "C:\Users\user\AppData\Local\Programs\Python\Python37\lib\site-packages\mode\utils\imports.py", line 115, in by_name f'{name!r} is not a valid name. {alt}') from exc
I have the same problem. I hope someone resolves this issue ASAP.
This project appears to have been abandoned.
You might want to check out the fork of this project - https://github.com/faust-streaming/faust
It has a bunch of fixes merged for problems that were in the base project.