dominikriemer opened a new issue, #4506: URL: https://github.com/apache/streampipes/issues/4506
### Discussed in https://github.com/apache/streampipes/discussions/4501 <div type='discussions-op-text'> <sup>Originally posted by **kruscho** May 25, 2026</sup> 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.</div> -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
