It would be nice to have a copy constructor into the class AbstractStream.
This constructor will allow to decorate KStreamImpl and KTableImpl APIs with new methods without impacting the public API.
I think, this can be special useful for community projects which would like to develop DSL extensions. This constructor will give access to the protected members of the AbstractStream.
I can made a PR if you think this change is possible.