Streaming Data Processing with Apache Kafka and KSQL

  1. Advanced ksqlDB Features
    1. Push vs. Pull Queries
      1. Push Queries
        1. Real-Time Result Streaming
          1. EMIT CHANGES Clause
            1. Continuous Subscriptions
            2. Pull Queries
              1. Point-in-Time Lookups
                1. Querying Materialized Views
                  1. Use Cases for Pull Queries
                    1. Query Limitations
                  2. User-Defined Functions (UDFs)
                    1. User-Defined Scalar Functions (UDF)
                      1. Creating Custom Functions
                        1. Registering UDFs
                          1. Function Implementation
                          2. User-Defined Aggregate Functions (UDAF)
                            1. Custom Aggregation Logic
                              1. State Management in UDAFs
                              2. User-Defined Table Functions (UDTF)
                                1. Producing Multiple Rows per Input
                                  1. Table Function Implementation
                                2. Data Serialization and Schema Management
                                  1. Role of Confluent Schema Registry
                                    1. Schema Registration
                                      1. Schema Validation
                                        1. Centralized Schema Management
                                        2. Working with AVRO Schemas
                                          1. Schema Definition
                                            1. Compatibility Modes
                                              1. Schema References
                                              2. Schema Evolution
                                                1. Backward Compatibility
                                                  1. Forward Compatibility
                                                    1. Managing Schema Changes
                                                      1. Breaking Changes

                                                  Previous

                                                  8. Joining Streams and Tables

                                                  Go to top

                                                  Next

                                                  10. Building Real-Time Applications