N × T → TMerge Typed Streams into One Pipeline
Combines multiple streams of the same message type.
When to use
Use Merge to converge equivalent branches without business logic.
Behavior
- Forwards values as they arrive from any source.
- Does not generate a function or alter the value type.
General properties
Identity, ownership and operator-specific mode.
typeTransformationTypeOperator kind. It controls available properties, valid sources and generated interfaces.
RequiredAllowed:Input, SubStream, Map, Filter, Join, MultiJoin, Process, FlatMap, FlatMapIterable, KeyBy, Merge, Split, Case, Sink, CycleLink, Error, Delay, WhennamestringHuman-readable stream name shown in the designer and used to derive default generated symbols.
RequiredserviceServiceService that owns the stream. Connected streams must belong to the same service.
RequiredConnections properties
Upstream graph references accepted by this operator.
sourcesStream[]Additional upstream streams. Source count and type constraints depend on the operator.
RequiredExecution properties
Pipeline placement and runtime policy.
pipelinestringNamed business-flow grouping inside the owning service; retained in generated configuration and runtime grouping metadata. It does not create connections.
Position properties
Designer-only canvas coordinates.
xPosnumberHorizontal designer coordinate. It has no runtime effect; missing positions can be supplied by layout.
yPosnumberVertical designer coordinate. It has no runtime effect; missing positions can be supplied by layout.
Configuration example
type: Merge
sources: [apiErrors, kafkaErrors]