Logstash to send events dynamically to kafka topics

Hi ,
Is there a way to send the events received from a s3 bucket to kafka dynamically.
Eg: First 10k events to one topic and next 10k events to other topic.

It should send based on the count of events .

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