Topologies: Sub-topology: 0 Source: KSTREAM-SOURCE-0000000000 (topics: [transactions]) --> KSTREAM-AGGREGATE-0000000005, KSTREAM-JOIN-0000000013, KSTREAM-MAPVALUES-0000000001 Processor: KSTREAM-AGGREGATE-0000000005 (stores: [txn-count-5m]) --> KTABLE-TOSTREAM-0000000006 <-- KSTREAM-SOURCE-0000000000 Processor: KSTREAM-MAPVALUES-0000000001 (stores: []) --> score <-- KSTREAM-SOURCE-0000000000 Processor: KTABLE-TOSTREAM-0000000006 (stores: []) --> KSTREAM-FILTER-0000000007 <-- KSTREAM-AGGREGATE-0000000005 Processor: KSTREAM-FILTER-0000000007 (stores: []) --> KSTREAM-MAP-0000000008 <-- KTABLE-TOSTREAM-0000000006 Processor: score (stores: []) --> KSTREAM-FILTER-0000000003 <-- KSTREAM-MAPVALUES-0000000001 Processor: KSTREAM-FILTER-0000000003 (stores: []) --> KSTREAM-SINK-0000000004 <-- score Processor: KSTREAM-JOIN-0000000013 (stores: [blocked-cards-STATE-STORE-0000000010]) --> KSTREAM-SINK-0000000014 <-- KSTREAM-SOURCE-0000000000 Processor: KSTREAM-MAP-0000000008 (stores: []) --> KSTREAM-SINK-0000000009 <-- KSTREAM-FILTER-0000000007 Source: KSTREAM-SOURCE-0000000011 (topics: [blocked-cards]) --> KTABLE-SOURCE-0000000012 Sink: KSTREAM-SINK-0000000004 (topic: alerts) <-- KSTREAM-FILTER-0000000003 Sink: KSTREAM-SINK-0000000009 (topic: alerts) <-- KSTREAM-MAP-0000000008 Sink: KSTREAM-SINK-0000000014 (topic: alerts) <-- KSTREAM-JOIN-0000000013 Processor: KTABLE-SOURCE-0000000012 (stores: [blocked-cards-STATE-STORE-0000000010]) --> none <-- KSTREAM-SOURCE-0000000011