streamnative/pulsar-beat-output

Topic Does not support dynamic configuration?

hailin0 opened this issue · 3 comments

"Topic" Does not support dynamic configuration?

@tuteng waiting for your help...


example:

output.kafka:
hosts: ["kafka1:9092"]
topic: '%{[fields.log_topic]}'

sijie commented

@tuteng can you help with this issue?

I am very sorry for the late reply. I will spend some time looking at this problem.

I may need to redesign it and implement this feature.