benthosdev / benthos

Fancy stream processing made operationally mundane
https://www.benthos.dev
MIT License
7.68k stars 752 forks source link

Implement BatchInput instead of Input for nats_jetstream #2510

Open GeorgeGkinis opened 1 month ago

GeorgeGkinis commented 1 month ago

I see that nats_jetstream fetches messages with a batch size of 1

Would it not increase performance to implement the BatchInput interface instead of Input when fetching from a NATS Jetstream? Adding batchSize as a config parameter and setting to 1 would behave the same as the current implementation.