Hello folks, I'd like to start the discussion for KIP-598:
https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=148648762 It proposes to augment the topology description's sub-classes with store and source / sink serde information. Let me know what you think, thanks! -- -- Guozhang