示例

总览

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

依赖

  • 增加 maven 依赖

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

代码

  • 我们以单元测试用例的方式提供了两个客户端用例, 你可以更换其中的参数并在自己的集群上实践;
  • 在我们提供的用例中,需要Apache PulsarApache 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客户端时有任何疑问,请及时与我们沟通