dynamic topic kafka

[taquanghung1705199]

I have a question that:
I'm source from http and sink to kafka

I want when I send log to http have path is: / => log is sent to kafka with topic
Ex:
source /aaa => topic aaa
source /bbb => topic bbb
source /ccc => topic ccc

How to do this ?

[spencergilbert]

👋
Hi @taquanghung1705199, the topic is template-able, you would set it with a template syntax that resolves to the path.

Ex, with the default path_key of "path":

topic = "{{ path }}"

[taquanghung1705199]

thanks
I got it!