I think we can leverage on https://cwiki.apache.org/confluence/display/KAFKA/KIP-307%3A+Allow+to+define+custom+processor+names+with+KStreams+DSL, i.e. to do the following in a follow-up PR (part ):
1) Add the Named interface. 2) Let Suppressed extend Named. 3) Use that name to name a) storeName, and hence its corresponding store name, b) processor name. [ Full content available at: https://github.com/apache/kafka/pull/5724 ] This message was relayed via gitbox.apache.org for [email protected]
