Fixes #31152: emit Snowflake Sink lineage in the KafkaConnect connector - #31153

Open

ulixius9 wants to merge 16 commits into

mainfrom

west-monroe

Commits on Aug 6, 2026

feat(kafkaconnect): derive Snowflake table names from topic names
ulixius9
committed
db8688b
feat(kafkaconnect): carry source topic and FQN qualification on dataset details
ulixius9
committed
3efa14f
feat(kafkaconnect): add sink dataset resolver registry with default strategy
ulixius9
committed
9383d5d
feat(kafkaconnect): resolve Snowflake sink datasets from topics and topic2table.map
ulixius9
committed
fcda5e0
refactor(kafkaconnect): resolve sink datasets through the resolver registry
ulixius9
committed
d51af4e
fix(kafkaconnect): restore instance dispatch for _resolver_for, fix test idiom
ulixius9
committed
0055865
feat(kafkaconnect): resolve Snowflake services and build four-part table FQNs
ulixius9
committed
dfcde46
fix(kafkaconnect): match Snowflake services by account and harden the CDC FQN guard

ulixius9
and
claude
committed
01930a8
refactor(kafkaconnect): drop unreachable Confluent Cloud config-array branch
ulixius9
committed
ca696c9
test(kafkaconnect): lock in observed Snowflake sink column and table shapes
ulixius9
committed
9524ef9
test(kafkaconnect): assert real sink column lineage edges end to end

ulixius9
and
claude
committed
0ce230c
feat(kafkaconnect): map flattened nested fields to Snowflake columns

ulixius9
and
claude
committed
38a5a23
fix(kafkaconnect): resolve flattened fields by path, not by name

ulixius9
and
claude
committed
0cd3834
fix(kafkaconnect): report the real connector hostname in lineage diagnostics

ulixius9
and
claude
committed
646c88d
fix(kafkaconnect): unbreak static-checks and make the Snowflake resolver a superset

ulixius9
and
claude
committed
444bd39

Commits on Aug 7, 2026

fix(kafkaconnect): anonymise sink fixtures and stop dropping snowflake datasets

ulixius9
and
claude
committed
baf5766

Navigation Menu

Uh oh!

Fixes #31152: emit Snowflake Sink lineage in the KafkaConnect connector - #31153

Fixes #31152: emit Snowflake Sink lineage in the KafkaConnect connector#31153
ulixius9 wants to merge 16 commits into
mainfrom
west-monroe

Commits on Aug 6, 2026

feat(kafkaconnect): derive Snowflake table names from topic names

feat(kafkaconnect): carry source topic and FQN qualification on dataset details

feat(kafkaconnect): add sink dataset resolver registry with default strategy

feat(kafkaconnect): resolve Snowflake sink datasets from topics and topic2table.map

refactor(kafkaconnect): resolve sink datasets through the resolver registry

fix(kafkaconnect): restore instance dispatch for _resolver_for, fix test idiom

feat(kafkaconnect): resolve Snowflake services and build four-part table FQNs

fix(kafkaconnect): match Snowflake services by account and harden the CDC FQN guard

refactor(kafkaconnect): drop unreachable Confluent Cloud config-array branch

test(kafkaconnect): lock in observed Snowflake sink column and table shapes

test(kafkaconnect): assert real sink column lineage edges end to end

feat(kafkaconnect): map flattened nested fields to Snowflake columns

fix(kafkaconnect): resolve flattened fields by path, not by name

fix(kafkaconnect): report the real connector hostname in lineage diagnostics

fix(kafkaconnect): unbreak static-checks and make the Snowflake resolver a superset

Commits on Aug 7, 2026

fix(kafkaconnect): anonymise sink fixtures and stop dropping snowflake datasets