Improve source connector's schema generation mechanism

[swenzel]

At the moment the source connector infers key and value schemas on first write. We should force subclasses to implement their own schema generation and expose the instance attributes holding the schemas so they can be overwritten on demand.