[Verse 1] Your Streams app containers need a home beside The Strimzi brokers running synchronized Deploy them side by side within the same namespace Where topics flow and processing takes place Configure your dockerfile with the JAR inside Mount volumes where your state stores will reside [Chorus] State stores persist, queries resist the crash RocksDB beneath, data you can rehash Scale horizontal, partitions divisional Interactive calls through REST provisional Streams and ksqlDB, deploy strategically Kubernetes pods orchestrating seamlessly [Verse 2] Persistent volumes claim the storage space RocksDB files need a permanent place When pods restart your changelog topics restore The local state from Kafka's durable store Set cleanup policy to compact not delete Keep your state stores consistent and complete [Chorus] State stores persist, queries resist the crash RocksDB beneath, data you can rehash Scale horizontal, partitions divisional Interactive calls through REST provisional Streams and ksqlDB, deploy strategically Kubernetes pods orchestrating seamlessly [Verse 3] Interactive queries expose internal state REST endpoints serve data without the wait Discovery service maps which pod holds what Partition assignments determine the slot Configure your service mesh for pod-to-pod calls Load balance requests across processing walls [Bridge] Scaling patterns match your partition count One consumer per partition paramount Add replicas when your load increases high StatefulSets ensure consistent node supply ksqlDB clusters join the Kubernetes dance Push queries streaming, pull queries on demand [Outro] Monitor your lag and watch the throughput flow Persistent storage keeps your state below Streams applications, ksqlDB in formation Kubernetes orchestrates the stream transformation
← 3 Schema Registry Integration | 5 Custom Operator Extensions →