Open dosp0911 opened 3 years ago
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.
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.