Thanks @mloubser
So you can either add kafka broker using endpoints.yml or as a script. I am trying to use enpoints.yml and it says TypeError: __init__() got an unexpected keyword argument 'client_id' sys:1: RuntimeWarning: coroutine 'BaseEventLoop.create_server' was never awaited
Can you help me here?
Here are the complete logs.
Traceback (most recent call last):
File "c:\users\tejasuw\anaconda3\envs\venv\lib\site-packages\sanic\app.py", line 1167, in run
serve(**server_settings)
File "c:\users\tejasuw\anaconda3\envs\venv\lib\site-packages\sanic\server.py", line 892, in serve
trigger_events(before_start, loop)
File "c:\users\tejasuw\anaconda3\envs\venv\lib\site-packages\sanic\server.py", line 668, in trigger_events
loop.run_until_complete(result)
File "c:\users\tejasuw\anaconda3\envs\venv\lib\asyncio\base_events.py", line 583, in run_until_complete
return future.result()
File "c:\users\tejasuw\anaconda3\envs\venv\lib\site-packages\rasa\core\run.py", line 244, in load_agent_on_start
_broker = EventBroker.create(endpoints.event_broker)
File "c:\users\tejasuw\anaconda3\envs\venv\lib\site-packages\rasa\core\brokers\broker.py", line 21, in create
return _create_from_endpoint_config(obj)
File "c:\users\tejasuw\anaconda3\envs\venv\lib\site-packages\rasa\core\brokers\broker.py", line 70, in _create_from_endpoint_config
broker = KafkaEventBroker.from_endpoint_config(endpoint_config)
File "c:\users\tejasuw\anaconda3\envs\venv\lib\site-packages\rasa\core\brokers\kafka.py", line 46, in from_endpoint_config
return cls(broker_config.url, **broker_config.kwargs)
TypeError: __init__() got an unexpected keyword argument 'client_id'
Traceback (most recent call last):
File "c:\users\tejasuw\anaconda3\envs\venv\lib\runpy.py", line 193, in _run_module_as_main
"__main__", mod_spec)
File "c:\users\tejasuw\anaconda3\envs\venv\lib\runpy.py", line 85, in _run_code
exec(code, run_globals)
File "c:\users\tejasuw\anaconda3\envs\venv\Scripts\rasa.exe\__main__.py", line 7, in <module>
File "c:\users\tejasuw\anaconda3\envs\venv\lib\site-packages\rasa\__main__.py", line 91, in main
cmdline_arguments.func(cmdline_arguments)
File "c:\users\tejasuw\anaconda3\envs\venv\lib\site-packages\rasa\cli\run.py", line 114, in run
rasa.run(**vars(args))
File "c:\users\tejasuw\anaconda3\envs\venv\lib\site-packages\rasa\run.py", line 56, in run
**kwargs,
File "c:\users\tejasuw\anaconda3\envs\venv\lib\site-packages\rasa\core\run.py", line 217, in serve_application
endpoints.lock_store if endpoints else None
File "c:\users\tejasuw\anaconda3\envs\venv\lib\site-packages\sanic\app.py", line 1167, in run
serve(**server_settings)
File "c:\users\tejasuw\anaconda3\envs\venv\lib\site-packages\sanic\server.py", line 892, in serve
trigger_events(before_start, loop)
File "c:\users\tejasuw\anaconda3\envs\venv\lib\site-packages\sanic\server.py", line 668, in trigger_events
loop.run_until_complete(result)
File "c:\users\tejasuw\anaconda3\envs\venv\lib\asyncio\base_events.py", line 583, in run_until_complete
return future.result()
File "c:\users\tejasuw\anaconda3\envs\venv\lib\site-packages\rasa\core\run.py", line 244, in load_agent_on_start
_broker = EventBroker.create(endpoints.event_broker)
File "c:\users\tejasuw\anaconda3\envs\venv\lib\site-packages\rasa\core\brokers\broker.py", line 21, in create
return _create_from_endpoint_config(obj)
File "c:\users\tejasuw\anaconda3\envs\venv\lib\site-packages\rasa\core\brokers\broker.py", line 70, in _create_from_endpoint_config
broker = KafkaEventBroker.from_endpoint_config(endpoint_config)
File "c:\users\tejasuw\anaconda3\envs\venv\lib\site-packages\rasa\core\brokers\kafka.py", line 46, in from_endpoint_config
return cls(broker_config.url, **broker_config.kwargs)
TypeError: __init__() got an unexpected keyword argument 'client_id'
sys:1: RuntimeWarning: coroutine 'BaseEventLoop.create_server' was never awaited```