Error issue when configuring ElastAlert2 with kafka

[Nghia10a5]

Hello everyone, I am configuring Alert for ELK specifically ElastAlert2, Because I have a push notification system that will read logs from the kafka topic. My goal: Want to install ElastAlert2, configure to push error log to kafka topic. Then my push notification system will read Kafka to send Alerts to my workchat.

I'm getting the error:

1. I want to know if ElastAlert2 supports Kafka? In the requirements.txt file, the kafka-python package is not found.
2. I am getting an error when running the command python3.9 -m elastalert.elastalert --verbose --rule rules/example_frequency.yaml Not sure where the error is. Can anyone help me with this problem? I will send detailed error information

Thanks team!

[Nghia10a5]

file error alert.txt