|
6201 | 6201 | }, |
6202 | 6202 | { |
6203 | 6203 | "name": "Kafka Streams Topology Design", |
6204 | | - "description": "Kafka Streams Topology Design is an open standard dedicated to the clear and effective description and visualisation of Kafka Stream topologies.\r\nKSTD covers all Kafka Streams DSL operators, as well as essential infrastructure and architectural building blocks.", |
| 6204 | + "description": "Kafka Streams Topology Design is an open standard dedicated to the clear and effective description and visualisation of Kafka Stream topologies. KSTD covers all Kafka Streams DSL operators, as well as essential infrastructure and architectural building blocks.", |
6205 | 6205 | "authors": [ |
6206 | 6206 | { |
6207 | 6207 | "name": "Hartmut Armbruster", |
6208 | 6208 | "github": "https://github.com/hartmut-co-uk", |
6209 | | - "twitter": "https://twitter.com/TheThrivingDev", |
| 6209 | + "twitter": "", |
6210 | 6210 | "url": "https://kstd.thriving.dev/" |
6211 | 6211 | } |
6212 | 6212 | ], |
6213 | 6213 | "source": "hartmut-co-uk/kafka-streams-topology-design.excalidrawlib", |
6214 | 6214 | "preview": "hartmut-co-uk/kafka-streams-topology-design.jpg", |
6215 | 6215 | "created": "2024-09-07", |
6216 | | - "updated": "2024-09-07", |
| 6216 | + "updated": "2025-04-06", |
6217 | 6217 | "version": 2, |
6218 | 6218 | "itemNames": [ |
6219 | 6219 | "Header", |
6220 | 6220 | "Topology", |
6221 | 6221 | "Sub-topology", |
6222 | | - "Apache Kafka Logo", |
| 6222 | + "Apache Kafka® Logo", |
6223 | 6223 | "Topic Simple", |
6224 | 6224 | "Topic Default", |
6225 | 6225 | "Topic Advanced", |
6226 | | - "Record", |
| 6226 | + "Record/Message/Event", |
6227 | 6227 | "Key-Value Record", |
6228 | 6228 | "Key-Value Record Typed", |
6229 | 6229 | "KStream", |
|
6234 | 6234 | "mapValues", |
6235 | 6235 | "flatMap", |
6236 | 6236 | "flatMapValues", |
6237 | | - "split", |
| 6237 | + "split +branch", |
6238 | 6238 | "merge", |
6239 | 6239 | "join", |
6240 | | - "join (alt)", |
| 6240 | + "fk join", |
6241 | 6241 | "repartition", |
6242 | 6242 | "selectKey", |
6243 | 6243 | "groupBy", |
6244 | | - "reduce/aggregate", |
| 6244 | + "windowedBy", |
| 6245 | + "reduce; aggregate", |
6245 | 6246 | "count", |
6246 | 6247 | "peek", |
6247 | 6248 | "forEach", |
6248 | | - "stateful", |
6249 | | - "stateful (alt)", |
6250 | | - "repartitioned", |
6251 | | - "repartitioned (alt)", |
6252 | 6249 | "process", |
6253 | 6250 | "processValues", |
6254 | 6251 | "transformValues", |
6255 | | - "State Store", |
6256 | | - "windowed", |
6257 | 6252 | "Punctuator", |
6258 | 6253 | "Partitioner", |
| 6254 | + "State Store", |
| 6255 | + "Windowed", |
| 6256 | + "stateful", |
| 6257 | + "stateful (alt)", |
| 6258 | + "repartitioned", |
| 6259 | + "repartitioned (alt)", |
6259 | 6260 | "Store Type RocksDB", |
6260 | 6261 | "Store Type InMemory", |
6261 | 6262 | "Store Type LRUCache", |
6262 | 6263 | "Store Variant Global", |
6263 | 6264 | "Store Variant Versioned", |
6264 | 6265 | "Store Variant Read-only", |
6265 | | - "Store Attribute Logged", |
6266 | | - "Store Attribute Not Logged", |
6267 | | - "Store Attribute Cached", |
6268 | | - "Store Attribute Not Cached", |
| 6266 | + "Emit onUpdate", |
| 6267 | + "Emit onClose", |
| 6268 | + "Suppressed", |
| 6269 | + "Logged", |
| 6270 | + "Not Logged", |
| 6271 | + "Cached", |
| 6272 | + "Not Cached", |
6269 | 6273 | "API", |
6270 | | - "API (alt1)", |
6271 | | - "API (alt2)", |
| 6274 | + "API (alt)", |
6272 | 6275 | "External System", |
6273 | | - "External System (alt1)", |
6274 | | - "External System (alt2)", |
| 6276 | + "External System (alt)", |
| 6277 | + "External DB", |
6275 | 6278 | "Numeric Indicator", |
6276 | 6279 | "Marker Success", |
6277 | 6280 | "Marker Alert", |
6278 | 6281 | "Marker Info", |
6279 | 6282 | "Marker Warn", |
6280 | 6283 | "Inline Note", |
6281 | | - "Callout", |
| 6284 | + "Callout Note", |
6282 | 6285 | "Descriptions Box", |
6283 | 6286 | "Legend Landscape", |
6284 | 6287 | "Legend Portrait", |
|
0 commit comments