Kafka to logstash , with dynamic topic creation

Elastic Stack Logstash
1

I have a question ; i need to know if logstash can handle the creation of topics kafka dynamically basing on feilds ! as un output !

the pipeline is kafka input --> logstash --> kafka output

the use case is kubernetes and we want to seperate namespaces logs for evry topic !

is that possible with logstash ?

2

The code does sprintf topic_id, so it can be based on a field value.

3

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.