Chalk Streaming

When to Use

• Writing a new make_stream_resolver (Kafka, Kinesis, PubSub)
• Choosing or debugging a parse expression (JSON, Avro, protobuf, header filtering)
• Testing stream parsing with test_streaming_resolver / check_stream_parsing
• Configuring deduplication, late arrival, or feature time
• Tuning throughput (batch size, poll records, resource groups)
• Understanding how stream workers communicate with engine-grpc
• Setting up materialized windowed aggregations driven by streaming data

Minimal Example