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
- Can I use my custom class when I use the adding-a-kafka-event-broker-using-the-endpoint-configuration method
- 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,