feat(streaming): declare every Kafka record shape in FLUID, checked before deploy by fas89 · Pull Request #817 · Agenticstiger/forge-cli

feat(streaming): declare Kafka record shapes in FLUID and check outputs before deploy

fas89

committed

8ed2874

security(streaming): run a contract's own SQL only when the operator lists it

fas89

committed

c5e74ca

feat(odcs): export where each stream-mapped column is read from

fas89

committed

44c6960

feat(diff): classify changes to what a streaming build reads

fas89

committed

436e602

docs(examples): flatten and reshape one Kafka stream into two products

fas89

committed

cecf0d2

test(streaming): prove both record shapes live from keyed records with headers

fas89

committed

b3da92c

fix(streaming): run the live fixture on S3Mock now that MinIO's images are gone

fas89

committed

4ab3e06

security(streaming): check each managed build as itself, never one found by id

fas89

committed

85ffcff

security(streaming): pin a listed contract SQL to the digest of what was reviewed

fas89

committed

770dc4e

fix(diff): report a streaming build that starts, changes or stops running its own SQL

fas89

committed

e336c07

fix(streaming): find mapped nested fields once, and name the path a mapping error is about

fas89

committed

3bee405

test(streaming): drift the stream with the output in the live refusal proof

fas89

committed

d050ac3

fix(streaming): refuse what Kafka and Flink refuse, and fail with a message, not a crash

fas89

committed

7c9690b

fix(streaming): build null-propagated structs as Flink plans them, keeping required fields

fas89

committed

f5d5fc7

fix(schema): only a managed Flink build may leave out its sql

fas89

committed

98a89de

fix(diff): report a stream build added with its own SQL, a stream dropped, and a cast changed

fas89

committed

98f0836

test(streaming): pin the checks inside containers, through conversions, and the gate's order

fas89

committed

ee47eb0

Navigation Menu

Repository navigation

feat(streaming): declare every Kafka record shape in FLUID, checked before deploy - #817

feat(streaming): declare every Kafka record shape in FLUID, checked before deploy#817
fas89 merged 17 commits into
feat/managed-flink-iceberg-streamingfrom
feat/flink-kafka-record-shapes

Commits on Nov 4, 2026

feat(streaming): declare Kafka record shapes in FLUID and check outputs before deploy

security(streaming): run a contract's own SQL only when the operator lists it

feat(odcs): export where each stream-mapped column is read from

feat(diff): classify changes to what a streaming build reads

docs(examples): flatten and reshape one Kafka stream into two products

test(streaming): prove both record shapes live from keyed records with headers

fix(streaming): run the live fixture on S3Mock now that MinIO's images are gone

security(streaming): check each managed build as itself, never one found by id

security(streaming): pin a listed contract SQL to the digest of what was reviewed

fix(diff): report a streaming build that starts, changes or stops running its own SQL

fix(streaming): find mapped nested fields once, and name the path a mapping error is about

test(streaming): drift the stream with the output in the live refusal proof

fix(streaming): refuse what Kafka and Flink refuse, and fail with a message, not a crash

fix(streaming): build null-propagated structs as Flink plans them, keeping required fields

fix(schema): only a managed Flink build may leave out its sql

fix(diff): report a stream build added with its own SQL, a stream dropped, and a cast changed

test(streaming): pin the checks inside containers, through conversions, and the gate's order