Set partition id as option

[ram-pi]

It would be very useful to have the possibility of selecting the partition id.
So it could possible to read from a particular partition.

[moritz-tr]

I think you can handle this via a condition on the @metadata field. Make sure to set the decorate_events => true on the azure_event input to access this field. Your output should look like this:

output {
if [@metadata][azure_event_hubs][partition] == "0" {
    elasticsearch { ... }
  }
}

[ram-pi]

Is there something similar on the input side I can do?