TubeMQ

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

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>1.12.0</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