# Send to a stream or queue

Publish / stream

produce to a queue or stream

Page: <https://meridian.online/operations/send-to-a-stream-or-queue>

## Status

Not built yet.

arcform does not do this yet. [Its place on the roadmap](https://meridian.online/roadmap#send-to-a-stream-or-queue)

## Variants

- Publish rows to a message broker: Send each row as a message to a topic, queue or stream on a broker such as Kafka, JMS, MQTT or Kinesis.
- [Send rows over a socket or pipe](https://meridian.online/operations/send-to-a-stream-or-queue/send-rows-over-a-socket-or-pipe): Write rows straight to a listening network socket, a UDP or syslog endpoint, a named pipe or another instance, with no broker in between.

## What other tools call it

Meridian's classification; an independent blind rating agreed on 86.2% of 312 rows (exact class, version 2).

- Duckle: [`Streaming sinks outside DuckDB (family)`](https://github.com/slothflowlabs/duckle/blob/f85f8960edfb6efbf4cb89d58a7b32e16df0e867/frontend/src/workflow-ui/palette-data.ts) (read 2026-09-25)
- Apache Hop: [`Azure Event Hubs writer`](https://hop.apache.org/manual/latest/pipeline/transforms/azure-event-hubs-writer.html) (read 2026-09-27)
- Apache Hop: [`Beam GCP Pub/Sub: publish`](https://hop.apache.org/manual/latest/pipeline/transforms/beamgcppublisher.html) (read 2026-09-27)
- Apache Hop: [`Beam Kafka produce`](https://hop.apache.org/manual/latest/pipeline/transforms/beamkafkaproduce.html) (read 2026-09-27)
- Apache Hop: [`Beam Kinesis produce`](https://hop.apache.org/manual/latest/pipeline/transforms/beamkinesisproduce.html) (read 2026-09-27)
- Apache Hop: [`JMS producer`](https://hop.apache.org/manual/next/pipeline/transforms/jms-producer.html) (read 2026-09-27)
- Apache Hop: [`Kafka producer`](https://hop.apache.org/manual/latest/pipeline/transforms/kafkaproducer.html) (read 2026-09-27)
- Apache NiFi: [`AzureEventHubRecordSink`](https://nifi.apache.org/components/org.apache.nifi.services.azure.eventhub.AzureEventHubRecordSink/) (read 2026-09-27)
- Apache NiFi: [`Message queue and stream publisher processors (family)`](https://nifi.apache.org/components/) (read 2026-09-27)
- Apache NiFi: [`Network sender processors (family)`](https://nifi.apache.org/components/) (read 2026-09-27)
- Apache NiFi: [`SiteToSiteReportingRecordSink`](https://nifi.apache.org/components/org.apache.nifi.reporting.sink.SiteToSiteReportingRecordSink/) (read 2026-09-27)
- Apache NiFi: [`UDPEventRecordSink`](https://nifi.apache.org/components/org.apache.nifi.record.sink.event.UDPEventRecordSink/) (read 2026-09-27)
- Pentaho Data Integration: [`AMQP Producer`](https://docs.pentaho.com/pdia-data-integration/9.3-data-integration/pdi-transformation-steps-reference-overview) (read 2026-09-27)
- Pentaho Data Integration: [`IBM WebSphere MQ Producer (deprecated)`](https://docs.pentaho.com/pdia-data-integration/9.3-data-integration/pdi-transformation-steps-reference-overview) (read 2026-09-27)
- Pentaho Data Integration: [`JMS Producer`](https://docs.pentaho.com/pdia-data-integration/9.3-data-integration/pdi-transformation-steps-reference-overview) (read 2026-09-27)
- Pentaho Data Integration: [`JMS producer (deprecated)`](https://docs.pentaho.com/pdia-data-integration/9.3-data-integration/pdi-transformation-steps-reference-overview) (read 2026-09-27)
- Pentaho Data Integration: [`Kafka Producer`](https://docs.pentaho.com/pdia-data-integration/9.3-data-integration/pdi-transformation-steps-reference-overview) (read 2026-09-27)
- Pentaho Data Integration: [`Kinesis Producer`](https://docs.pentaho.com/pdia-data-integration/9.3-data-integration/pdi-transformation-steps-reference-overview) (read 2026-09-27)
- Pentaho Data Integration: [`MQTT Producer`](https://docs.pentaho.com/pdia-data-integration/9.3-data-integration/pdi-transformation-steps-reference-overview) (read 2026-09-27)
- Pentaho Data Integration: [`Socket writer`](https://docs.pentaho.com/pdia-data-integration/9.3-data-integration/pdi-transformation-steps-reference-overview) (read 2026-09-27)
- RapidMiner Studio: [`Write Kafka Topic`](https://docs.rapidminer.com/latest/studio/operators/extensions/Kafka%20Connector/kafka/write_kafka_topic.html) (read 2026-09-27)
- Talend: [`Messaging output components (family)`](https://help.qlik.com/talend/en-US/components/8.0/About) (read 2026-09-27)
- Talend: [`tNamedPipeOutput`](https://help.qlik.com/talend/en-US/components/8.0/namedpipe/namedpipe-component) (read 2026-09-27)
- Talend: [`tRouteOutput`](https://help.qlik.com/talend/en-US/components/8.0/route/route-component) (read 2026-09-27)
- Talend: [`tSocketOutput`](https://help.qlik.com/talend/en-US/components/8.0/socket/socket-component) (read 2026-09-27)