Skip to content

Implement use of fiware-datamodel header#31

Merged
AlvaroVega merged 5 commits intomainfrom
issue/fiware-datamodel
Feb 24, 2026
Merged

Implement use of fiware-datamodel header#31
AlvaroVega merged 5 commits intomainfrom
issue/fiware-datamodel

Conversation

@GregorioBlazquez
Copy link
Collaborator

Related Issue: telefonicaid/kafnus#190

This PR implements dynamic datamodel resolution in the HeaderRouter SMT.

If the fiware-datamodel header is present and not empty, it overrides the configured datamodel. Otherwise, the connector falls back to its static configuration (defaulting to dm-by-entity-type-database).

This enables per-record routing without requiring multiple connectors and keeps SQL layout logic centralized in Kafka Connect.

Copy link
Member

@AlvaroVega AlvaroVega left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM

@AlvaroVega AlvaroVega merged commit 2a54468 into main Feb 24, 2026
1 check passed
@AlvaroVega AlvaroVega deleted the issue/fiware-datamodel branch February 24, 2026 12:40
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants