How to send alerts to Kafka cluster by kapacitor's tickscript?


I have written an issue on Kafka cluster cannot receive alerts · Issue #2017 · influxdata/kapacitor · GitHub with details

I wonder how to send alerts to kafka.
kapacitor 1.5.1

.crit(lambda: “Percent_Processor_Time” > 80)
.message(‘Hey, check your CPU’)

Everything seems OK, but kafka cluster cannot receive messages from my kapacitor.