(->edge from to)
(assign-id applicaton-id n)
(assign-ids applicaton-id g)
(base-node t n)
(collapse-merge-chains g)
(describe-node-dispatch n)
(describe-topology topology streams-config)
Returns a list of the stream graphs in a topology.
The passed in topology object must have a describe
method, meaning
it is one of:
Kafka >= 1.1 : https://kafka.apache.org/21/javadoc/org/apache/kafka/streams/Topology.html Kafka < 1.1 : https://kafka.apache.org/10/javadoc/org/apache/kafka/streams/processor/TopologyBuilder.html#internalTopologyBuilder
Each stream graph takes the form:
{:id <a unique UUID for the stream, deterministic from the encosing topology and its stream name> :type :stream :name <the name that kafka gives this stream> :nodes <a list of all the nodes in the graph> :edges <a list of all the edges in the graph>}
Nodes and edges are represented as:
{:id <a deterministic UUID for the node> :name <the name as assigned by kafka> :type <the type - processor, store, topic &c.>}
{:from <the :name of the node the edge comes from> :from-id <the :id of the node the edge comes from> :to <the :name of the node the edge goes to> :to-id <the :id of the node the edge goes to>}
All identifiers are v5 UUIDs, and are globally unique where objects are distinct and globally equal where objects are the same.
Returns a list of the stream graphs in a topology. The passed in topology object must have a `describe` method, meaning it is one of: Kafka >= 1.1 : https://kafka.apache.org/21/javadoc/org/apache/kafka/streams/Topology.html Kafka < 1.1 : https://kafka.apache.org/10/javadoc/org/apache/kafka/streams/processor/TopologyBuilder.html#internalTopologyBuilder Each stream graph takes the form: {:id <a unique UUID for the stream, deterministic from the encosing topology and its stream name> :type :stream :name <the name that kafka gives this stream> :nodes <a list of all the nodes in the graph> :edges <a list of all the edges in the graph>} Nodes and edges are represented as: {:id <a deterministic UUID for the node> :name <the name as assigned by kafka> :type <the type - processor, store, topic &c.>} {:from <the :name of the node the edge comes from> :from-id <the :id of the node the edge comes from> :to <the :name of the node the edge goes to> :to-id <the :id of the node the edge goes to>} All identifiers are v5 UUIDs, and are globally unique where objects are distinct and globally equal where objects are the same.
(gen-id applicaton-id n)
(good-edge e)
(is-merge? n)
(parse-description applicaton-id d)
(topic? s)
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close