Hey my current setup includes filebeat sending data to kafka. So i wanted to have control over data going into partition. So by making use of a unique key we can actually control it. So the question is .
Is there a way to make use of a field in logs as unique key. Say i have a log which is not in json format and contains a id in it. All the events with same id should go into a single partition in kafka topic. Can we achieve by making use of processor?
This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.