Is your request related to a problem you have?

One thing that would really help us out is to be able to build an in-memory Kafka broker, while keeping as much of the "metal" of KafkaFlow as possible. This isn't possible at the moment with the way the code connects to the Confluent producer/consumer builders.

Describe the solution you'd like

The ideal entry point for this is the IConsumer<TKey, TValue> and IProducer<TKey, TValue> interfaces, but these are being directly created in code. A simple solution would be to abstract these away in public builder interfaces that can be overridden in the DI container if desired.

I don't think we need config support here, as in, this is a very advanced scenario that probably doesn't need to be included in the configuration builders at this stage.

Are you able to help bring it to life and contribute with a Pull Request?

Yes

Additional context

No response