Connect rasa with Kafka

[lsouvleros (lefteris.souvleros)]

Hello,

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

Event Brokers

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

[tejasuw (teja vu)]

@lsouvleros did you figure this out?