Rasa + kafka

Hi, could someone provide me simple working example of using Kafka as Event Broker?

^ examples from docs are not working for me

In this line:

tracker_store = InMemoryTrackerStore(event_broker=kafka_broker)

I’m getting

Traceback (most recent call last):
  File "kafka_producer.py", line 7, in <module>
    tracker_store = InMemoryTrackerStore(event_broker=kafka_broker)
TypeError: __init__() missing 1 required positional argument: 'domain'

How am I supposed to get and pass domain here?

I’m using Rasa 1.2.4

hi @kaladin ! thanks for the question.

It looks like the docs are out of date. The InMemoryTrackerStore also takes a domain as an argument rasa/tracker_store.py at master · RasaHQ/rasa · GitHub

would you please check that works and create a PR to update the docs? many thanks!

Okay, but how am I supposed to run kafka producer? Do I have to run producer code as separate script or in actions.py? And how to pass domain into InMemoryTrackerStore? Do I need to retrive domain by HTTP API?