kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Sachin Mittal <sjmit...@gmail.com>
Subject Kafka Streams Topology describe format
Date Fri, 06 Dec 2019 18:21:28 GMT
Hi,
I am just posting a section of my topology to basically understand what
describe method actually displays.

What can we understand just by looking at the topology (like what does -->
and <-- arrows represent).

------------------------------------------------------------------------------------------------------------------------------------------------------------------
    Source: KSTREAM-SOURCE-0000000043 (topics:
[price-change-left-repartition])
      --> KSTREAM-WINDOWED-0000000047
    Source: KSTREAM-SOURCE-0000000046 (topics:
[price-change-right-repartition])
      --> KSTREAM-WINDOWED-0000000048
    Processor: KSTREAM-WINDOWED-0000000047 (stores:
[KSTREAM-JOINTHIS-0000000049-store])
      --> KSTREAM-JOINTHIS-0000000049
      <-- KSTREAM-SOURCE-0000000043
    Processor: KSTREAM-WINDOWED-0000000048 (stores:
[KSTREAM-OUTEROTHER-0000000050-store])
      --> KSTREAM-OUTEROTHER-0000000050
      <-- KSTREAM-SOURCE-0000000046
    Processor: KSTREAM-JOINTHIS-0000000049 (stores:
[KSTREAM-OUTEROTHER-0000000050-store])
      --> KSTREAM-MERGE-0000000051
      <-- KSTREAM-WINDOWED-0000000047
    Processor: KSTREAM-OUTEROTHER-0000000050 (stores:
[KSTREAM-JOINTHIS-0000000049-store])
      --> KSTREAM-MERGE-0000000051
      <-- KSTREAM-WINDOWED-0000000048
-------------------------------------------------------------------------------------------------------------------------------------------------------------------------

What I basically understand is that there are 2 sources converted into
windowed source using two of the processors.
There are 2 more subsequent processors which take some input and process
some output.
Ones marked by --> is the input and one marked by <-- is the ouput.
And the string next to Processor: or Source: is the name of the processor
or input of the source.

Is my understand correct or if I am missing something.

Thanks
Sachin

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message