You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Add an option to KafkaSink that allows users to specify a Kafka message key (static value, field-mapped value, or expression) so emitted records include a key. This enables consistent partitioning, message compaction compatibility, and easier downstream processing.
Kafka partitions messages by key; many consumers and topics expect keys for ordering, compaction, or lookup.
Current KafkaSink in StreamPipes emits messages without configurable keys, forcing users to implement workarounds (custom sinks, external producers).
Providing a first-class key configuration keeps user flows simple and consistent with StreamPipes’ low-code goals.
reacted with thumbs up emoji reacted with thumbs down emoji reacted with laugh emoji reacted with hooray emoji reacted with confused emoji reacted with heart emoji reacted with rocket emoji reacted with eyes emoji
Uh oh!
There was an error while loading. Please reload this page.
Add an option to KafkaSink that allows users to specify a Kafka message key (static value, field-mapped value, or expression) so emitted records include a key. This enables consistent partitioning, message compaction compatibility, and easier downstream processing.
All reactions