Possibility to change between different lower level Kafka clients

It could be a an idea to enable different underlying Kafka clients. This would need definition of a generic wrapper API for basic functionality like connect, disconnect, subscribe, unsubscribe, commit and seek.