Kafka Streams Topology Visualizer
Converts an ASCII Kafka Topology description into a hand drawn diagram.
Github link
.
Input Kafka Topology
update
Topology Sub-topologies: Sub-topology: 0 Source: KSTREAM-SOURCE-0000000000 (topics: [conversation-meta]) --> KSTREAM-TRANSFORM-0000000001 Processor: KSTREAM-TRANSFORM-0000000001 (stores: [conversation-meta-state]) --> KSTREAM-KEY-SELECT-0000000002 <-- KSTREAM-SOURCE-0000000000 Processor: KSTREAM-KEY-SELECT-0000000002 (stores: []) --> KSTREAM-FILTER-0000000005 <-- KSTREAM-TRANSFORM-0000000001 Processor: KSTREAM-FILTER-0000000005 (stores: []) --> KSTREAM-SINK-0000000004 <-- KSTREAM-KEY-SELECT-0000000002 Sink: KSTREAM-SINK-0000000004 (topic: count-resolved-repartition) <-- KSTREAM-FILTER-0000000005 Sub-topology: 1 Source: KSTREAM-SOURCE-0000000006 (topics: [count-resolved-repartition]) --> KSTREAM-AGGREGATE-0000000003 Processor: KSTREAM-AGGREGATE-0000000003 (stores: [count-resolved]) --> KTABLE-TOSTREAM-0000000007 <-- KSTREAM-SOURCE-0000000006 Processor: KTABLE-TOSTREAM-0000000007 (stores: []) --> KSTREAM-SINK-0000000008 <-- KSTREAM-AGGREGATE-0000000003 Sink: KSTREAM-SINK-0000000008 (topic: streams-count-resolved) <-- KTABLE-TOSTREAM-0000000007
Output Sketch Diagram
>
G
Kafka Streams Topology
cluster_0
Sub-topology: 0
cluster_1
Sub-topology: 1
KSTREAM-\nSOURCE-\n0000000000
KSTREAM-
SOURCE-
0000000000
KSTREAM-\nTRANSFORM-\n0000000001
KSTREAM-
TRANSFORM-
0000000001
KSTREAM-\nSOURCE-\n0000000000->KSTREAM-\nTRANSFORM-\n0000000001
KSTREAM-\nKEY-\nSELECT-\n0000000002
KSTREAM-
KEY-
SELECT-
0000000002
KSTREAM-\nTRANSFORM-\n0000000001->KSTREAM-\nKEY-\nSELECT-\n0000000002
conversation-\nmeta-\nstate
conversation-
meta-
state
KSTREAM-\nTRANSFORM-\n0000000001->conversation-\nmeta-\nstate
KSTREAM-\nFILTER-\n0000000005
KSTREAM-
FILTER-
0000000005
KSTREAM-\nKEY-\nSELECT-\n0000000002->KSTREAM-\nFILTER-\n0000000005
KSTREAM-\nSINK-\n0000000004
KSTREAM-
SINK-
0000000004
KSTREAM-\nFILTER-\n0000000005->KSTREAM-\nSINK-\n0000000004
count-\nresolved-\nrepartition
count-
resolved-
repartition
KSTREAM-\nSINK-\n0000000004->count-\nresolved-\nrepartition
KSTREAM-\nSOURCE-\n0000000006
KSTREAM-
SOURCE-
0000000006
KSTREAM-\nAGGREGATE-\n0000000003
KSTREAM-
AGGREGATE-
0000000003
KSTREAM-\nSOURCE-\n0000000006->KSTREAM-\nAGGREGATE-\n0000000003
KTABLE-\nTOSTREAM-\n0000000007
KTABLE-
TOSTREAM-
0000000007
KSTREAM-\nAGGREGATE-\n0000000003->KTABLE-\nTOSTREAM-\n0000000007
count-\nresolved
count-
resolved
KSTREAM-\nAGGREGATE-\n0000000003->count-\nresolved
KSTREAM-\nSINK-\n0000000008
KSTREAM-
SINK-
0000000008
KTABLE-\nTOSTREAM-\n0000000007->KSTREAM-\nSINK-\n0000000008
streams-\ncount-\nresolved
streams-
count-
resolved
KSTREAM-\nSINK-\n0000000008->streams-\ncount-\nresolved
conversation-\nmeta
conversation-
meta
conversation-\nmeta->KSTREAM-\nSOURCE-\n0000000000
count-\nresolved-\nrepartition->KSTREAM-\nSOURCE-\n0000000006