@guozhangwang a high-level question: Did you consider passing the serdes through the graph nodes instead of the DSL classes? I was thinking about this a little last night, and I think either approach would work fine for passing serdes forward, but to propagate them backward, we would need to have them on the graph.
It also seems like storing type information on the graph nodes would likely be beneficial in other contexts as well. [ Full content available at: https://github.com/apache/kafka/pull/5521 ] This message was relayed via gitbox.apache.org for [email protected]
