### Feature description This is needed to support https://github.com/ConduitIO/streaming-benchmarks/issues/6.
Feature description
This is needed to support ConduitIO/streaming-benchmarks#6.