示例

总览

Apache InLong Manager 是整个数据集成平台面向用户的统一管理入口。为方便用户使用在无界面的场景下部署InLong group任务，我们提供了Manager的客户端SDK。

依赖

  • 增加 maven 依赖

    1. <dependency>
    2.     <groupId>org.apache.inlong</groupId>
    3.     <artifactId>manager-client</artifactId>
    4.     <version>1.2.0-incubating</version>
    5. </dependency>

代码

  • 我们以单元测试用例的方式提供了两个客户端用例, 你可以更换其中的参数并在自己的集群上实践;
  • 在我们提供的用例中，需要Apache Pulsar及Apache Flink的支持。你可以在自己的Inlong集群上运行任务, 或借助第三方平台提供的相关服务运行。

参考Demo

  1. // Create client configuration
  2. ClientConfiguration configuration = createClientConfig();
  3. // Init Inlong client
  4. InlongClient inlongClient = InlongClient.create(SERVICE_URL, configuration);
  5. try {
  6.     // Create group conf
  7.     InlongGroupConf groupConf = createGroupConf();
  8.     // Init group resource by conf
  9.     InlongGroup group = inlongClient.forGroup(groupConf);
  10.     // Create stream conf
  11.     InlongStreamConf streamConf = createStreamConf();
  12.     // Create Stream builder 
  13.     InlongStreamBuilder streamBuilder = group.createStream(streamConf);
  14.     // Create stream source
  15.     streamBuilder.source(createSource());
  16.     // Create stream sink
  17.     streamBuilder.sink(createSink());
  18.     // Init stream 
  19.     streamBuilder.initOrUpdate();
  20.     // Start group in server
  21.     InlongGroupContext inlongGroupContext = group.init();
  22. } catch (Exception e) {
  23.     e.printStackTrace();
  24. }

Kafka2Hive

参考 manager-client-examples org.apache.inlong.manager.client.Kafka2HiveExample.java

Binlog2Kafka

参考 manager-client-examples org.apache.inlong.manager.client.Binlog2KafkaExample.java

写在最后

如果你在使用Manager客户端时有任何疑问，请及时与我们沟通