How about also augment the built `Topology` with processor APIs to add more processors, and check that as long as we do not call addStores the resulted topology would still be stateless.
[ Full content available at: https://github.com/apache/kafka/pull/5647 ] This message was relayed via gitbox.apache.org for [email protected]
