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

InfluxDB 1 Kapacitor
1

Hi,

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

stream
|from()
.measurement(‘win_cpu’)
|alert()
.crit(lambda: “Percent_Processor_Time” > 80)
.message(‘Hey, check your CPU’)
.kafka()
.cluster(‘kafka01’)
.kafkaTopic(‘cpu-alerts’)

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