First-party product documentation. Instructions are verified against the dFlow~IQ desktop implementation. Labels appear exactly as they do in the application where practical.
Define the pipeline
Pipeline nameUnique within the workspace, case-insensitively.
Source topicTopic read with read_committed isolation.
Target topicMust differ from the source.
Source positionEarliest retained or Latest retained tail.
Maximum recordsBetween 1 and 10,000.
Keys, values, headers and original timestamps are copied as raw bytes. Saved definitions never run automatically.
Create a dry-run plan
- Save the definition.
- Select Dry run.
- Wait while dFlow~IQ reads a bounded snapshot.
- Review record count, partition count, snapshot bytes and plan ID.
The snapshot is limited to 32 MiB and a 30-second broker-read deadline. A plan with no records cannot run.
Confirm and execute
- Select Run pipeline after a successful dry run.
- Read the at-least-once warning.
- Type the exact target topic into the confirmation field.
- Select Run pipeline and monitor broker-acknowledged progress.
Every run requires a fresh dry run. Cancellation, failure or editing invalidates the plan. An interruption can leave an in-flight result unknown, and retrying may create duplicates.