ModuleNotFoundError

[dosp0911]

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

[gazelle98]

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.

[bobh66]

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.