dFlow~IQ
dFlow~IQ manualChapter 04 · Application guide

Create producers and publish records

Configure serializer-aware producers, validate payloads locally, publish canaries and use bounded batch upload safely.

DOCUMENTED VERSIONdFlow~IQ Community 1.0

First-party product documentation. Instructions are verified against the dFlow~IQ desktop implementation. Labels appear exactly as they do in the application where practical.

04.1

Create a producer definition

  1. Choose Kafka → Producers → Create producer.
  2. Enter a unique Producer Name and select a Topic.
  3. Choose Key serializer and Value serializer independently.
  4. For schema-backed serialization, select the intended subject.
  5. Save the producer.

Available serializers include Int32, Int64, String, SchemaRegistry, UInt32, UInt64, Avro(Embedded), Base64, Hex and UUIDBinary.

04.2

Publish through the JSON editor

  1. Select Open Editor on the producer.
  2. Enter an optional key in the expected key format.
  3. Enter or upload the value.
  4. Review local JSON, numeric, binary or schema validation results.
  5. Select Publish and wait for the acknowledged topic, partition and offset.
  6. Read the exact result back before publishing more records.

The editor supports up to 32 KiB and 500 lines. Kafka acknowledgements are configured as all.

04.3

Work with schema-backed payloads

SchemaRegistry validates the payload against the selected Registry schema before publishing. Avro(Embedded) expects one JSON object containing both schema and payload.

schema

An Avro schema object.

payload

The datum that must conform to that schema.

Registry-framed Avro and embedded Avro object-container data are different wire formats. Match the producer to the existing consumer contract.

04.4

Use Batch Upload

  1. Select Batch Upload and choose a directory.
  2. dFlow~IQ recursively finds .json files and sorts their paths.
  3. Up to eight files are validated and published concurrently.
  4. Review Files processed, Files published and every per-file error.

The filename without .json becomes raw Kafka key bytes and does not pass through the configured key serializer. Validate this behaviour against the target contract before running a batch.

04.5

Generate a draft with AI

  1. Load a schema and select Ask AI.
  2. Choose a realistic, minimal or edge-case payload suggestion.
  3. Review the provider destination and shared context before sending.
  4. Select Use JSON in editor.
  5. Wait for local schema validation, then review every field yourself before publishing.

AI output is never automatically published.

Documentation reference

Current dFlow~IQ Community desktop implementation and bundled UI labels, reviewed 13 August 2026. Product behaviour takes precedence if a later release differs from this page.