[KafKa] is kafka sink not support dynamic topic

[onlylin]

Is kafka sink not support dynamic topic？

[ngjaying]

It should be supported. Did you find any issue?

[onlylin]

I read the kafka sink source code, I find the buildKafkaWriter method still use the topic in kafka config. I can't find where to parse the dynamic topic.

[ngjaying]

@onlylin you're right, the Kafka sink does not support dynamic topic yet. Refer to https://github.com/lf-edge/ekuiper/blob/master/internal/io/mqtt/sink.go about how to set dynamic topic