Hooking into a Kstream directly from code, rather than from a topic

[WhittlesJr]

Hi, our org just switched from Apache Camel to your lib, and we are liking it so far.

Question: is there any way to call a KStream directly with a function? Maybe I'm asking too high up the stack here but perhaps you know. With Camel, you could call! any route directly from your code synchronously or asynchronously, and it would flow through all the downstream routes as you've defined them. We'd like to do the same thing with Kafka Streams, given the key describing the stream in our Willa topology.