Connect rasa with Kafka


I am using python 3.7 with rasa 1.10.2. I would like to connect rasa with Kafka using PLAINTEXT security protocol. In order to achieve this, I have create a custom class which extend the fuctionality of KafkaEventBroker (rasa.core.brokers.kafka)

I have read the following documentation

I have two questions

  1. Can I use my custom class when I use the adding-a-kafka-event-broker-using-the-endpoint-configuration method
  2. I see the example of Adding a Kafka Broker in Python but I do not understand where should I run/call these code?

Thank you very much,

Lefteris Souvleros

@lsouvleros did you figure this out?