asmhatreandClaude Sonnet 5.5
59fcdbe079
Similarity scoring, a 5-minute windowed count that alerts once, and a KTable blocklist join, with the Spring wiring on Spring Boot 4.1.1 and Kafka Streams 4.2.1. Co-Authored-By: Claude Sonnet 5.5 <[email protected]> Claude-Session: https://claude.ai/code/session_01RjfyTgmERTWLqzafu34Cth
40 lines
1.6 KiB
Plaintext
40 lines
1.6 KiB
Plaintext
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
|