Allow Source connector to split DCP stream and write into separate topics

From the user perspective it should be extension class, which implements decision logic based on the mutation event from the DCP stream.

The state will be still associated with the partitions in the source stream.