Which use case/requirement will be addressed by the proposed feature?

We want to use Debezium Rabbitmq Native Stream sink and the Outbox pattern to publish messages to a stream. We'd like to leverage streaming features such as super streams for automatic partitioning, filtering, and forwarding fields to message headers.

Implementation ideas (optional)

We can use record headers to populate message application properties.

For super-streams, it might make sense to add a configuration option that creates a super-stream producer instead of a simple one when enabled.

For filtering, we can add a configuration property that specifies which field to extract from the message for filtering purposes.