---

title: TubeMQ sidebar_position: 11

import {siteVariables} from ‘../../version’;

Overview

Apache InLong TubeMQ is a distributed, open source pub-sub messaging and steaming platform for real-time workloads, trillions of massive data precipitation.

Version

Extract Node	Version
TubeMQ	TubeMQ: >=0.1.0

Dependencies

In order to set up the TubeMQ Extract Node, the following provides dependency information for both projects using a build automation tool (such as Maven or SBT) and SQL Client with Sort Connectors JAR bundles.

Maven dependency

<dependency>
    <groupId>org.apache.inlong</groupId>
    <artifactId>sort-connector-tubemq</artifactId>
    <version>${siteVariables.inLongVersion}</version>
</dependency>

How to create a TubeMQ Extract Node

Usage for SQL API

The example below shows how to create a TubeMQ Extract Node with Flink SQL Cli :

-- Create a TubeMQ table 'tube_extract_node' in Flink SQL Cli
Flink SQL>
CREATE TABLE tube_extract_node
(
    id     INT,
    name   STRING,
    age    INT,
    salary FLOAT
) WITH (
      'connector' = 'tubemq',
      'topic' = 'topicName',
      'master.rpc' = 'rpcUrl', -- 127.0.0.1:8715
      'format' = 'json',
      'group.name' = 'groupName');

-- Read data from tube_extract_node
Flink SQL>
SELECT *
FROM tube_extract_node;

Usage for InLong Dashboard

TODO

Usage for InLong Manager Client

TODO

TubeMQ Extract Node Options

Parameter	Required	Default value	Type	Description
connector	required	tubemq	String	Set the connector type. Available options are tubemq.
topic	required	(none)	String	Set the input or output topic
masterRpc	required	(none)	String	Set the TubeMQ master service address.
format	required	(none)	String	TubeMQ message value serialization format, support JSON, Avro, etc. For more information, see the Flink format.
groupId	required	(none)	String	Consumer group in TubeMQ

Available Metadata

The METADATA flag is used to read and write metadata in Tube messages. The support list is as follows.

Note The R/W column defines whether a metadata field is readable (R) and/or writable (W). Read-only columns must be declared VIRTUAL to exclude them during an INSERT INTO operation.

Key	Data Type	Description	R/W
topic	STRING NOT NULL	Topic name of the Tube message	R
consume_time	BIGINT	Consume time of the Tube message	R

Data Type Mapping

Tube stores message keys and values as bytes, so Tube doesn’t have schema or data types. The Tube messages are deserialized and serialized by formats, e.g. csv, json, avro. Thus, the data type mapping is determined by specific formats. Please refer to Formats pages for more details.