Skip to content

routing_key is not validated: a typo silently routes everything to one partition #84

Description

@lukashes

getPartitionKey falls back to the table name when the configured routing_key column is missing from the event, and swallows any error on the way (src/processor/processor.zig:171-188). A typo in routing_key (or the default id on a table without an id column) is never reported: every message gets the same key and lands in one partition, killing ordering-by-key and partition balance without a trace in the logs.

Ask: validate at startup that the routing key column exists on the configured table (next to the other table checks in the validator), and log a warning on the runtime fallback path.

Metadata

Metadata

Assignees

No one assigned

    Labels

    enhancementNew feature or request

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions