ekuiper icon indicating copy to clipboard operation
ekuiper copied to clipboard
verified publisher icon lf-edge

[KafKa] is kafka sink not support dynamic topic

Open onlylin opened this issue 8 months ago • 3 comments

Is kafka sink not support dynamic topic？

onlylin avatar Apr 30 '25 08:04 onlylin

It should be supported. Did you find any issue?

ngjaying avatar May 06 '25 01:05 ngjaying

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.

onlylin avatar May 06 '25 09:05 onlylin

@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

ngjaying avatar May 15 '25 02:05 ngjaying

Closed by #3831

ngjaying avatar Aug 25 '25 02:08 ngjaying