Example

    • We provide two unit cases for you to build your own group task, you can replace the predefined params and try it in your own cluster.
    • In following cases, Apache Pulsar and Apache Flink are needed when your group is inited. You can run Inlong group in your own cluster, or with the help of third-party services.
    1. ClientConfiguration configuration = createClientConfig();
    2. // Init Inlong client
    3. InlongClient inlongClient = InlongClient.create(SERVICE_URL, configuration);
    4. try {
    5.     // Create group conf
    6.     InlongGroupConf groupConf = createGroupConf();
    7.     // Init group resource by conf
    9.     // Create stream conf
    10.     InlongStreamConf streamConf = createStreamConf();
    11.     InlongStreamBuilder streamBuilder = group.createStream(streamConf);
    12.     // Create stream source
    13.     streamBuilder.source(createSource());
    14.     // Create stream sink
    16.     // Init stream 
    17.     streamBuilder.initOrUpdate();
    18.     // Start group in server
    19.     InlongGroupContext inlongGroupContext = group.init();
    20. } catch (Exception e) {
    21. }