diff options
| author | doufenghu <[email protected]> | 2024-11-13 00:04:20 +0800 |
|---|---|---|
| committer | doufenghu <[email protected]> | 2024-11-13 00:04:20 +0800 |
| commit | b636c24d8349cd3ddd306e8a9561724fbd0d2b4c (patch) | |
| tree | 830650f55480ec66e335450fa217a26e844ece19 /groot-examples | |
| parent | 73a5f46181af3c9e596e8b08dc27f63339b04c53 (diff) | |
[Feature][API] 统一Operator实例生成接口为Factory. Connector Factory Identifier 统一为type，与任务配置文件保持一致.
Diffstat (limited to 'groot-examples')
3 files changed, 3 insertions, 3 deletions
diff --git a/groot-examples/end-to-end-example/src/main/java/com/geedgenetworks/example/GrootStreamExample.java b/groot-examples/end-to-end-example/src/main/java/com/geedgenetworks/example/GrootStreamExample.java index 9b58289..5e64962 100644 --- a/groot-examples/end-to-end-example/src/main/java/com/geedgenetworks/example/GrootStreamExample.java +++ b/groot-examples/end-to-end-example/src/main/java/com/geedgenetworks/example/GrootStreamExample.java @@ -14,7 +14,7 @@ import java.util.List; public class GrootStreamExample { public static void main(String[] args) throws FileNotFoundException, URISyntaxException { - String configPath = args.length > 0 ? args[0] : "/examples/inline_to_print.yaml"; + String configPath = args.length > 0 ? args[0] : "/examples/inline_to_print_test.yaml"; String configFile = getTestConfigFile(configPath); ExecuteCommandArgs executeCommandArgs = new ExecuteCommandArgs(); executeCommandArgs.setConfigFile(configFile); diff --git a/groot-examples/end-to-end-example/src/main/resources/examples/kafka_to_print.yaml b/groot-examples/end-to-end-example/src/main/resources/examples/kafka_to_print.yaml index aafd642..8eaa567 100644 --- a/groot-examples/end-to-end-example/src/main/resources/examples/kafka_to_print.yaml +++ b/groot-examples/end-to-end-example/src/main/resources/examples/kafka_to_print.yaml @@ -4,7 +4,7 @@ sources: schema: properties: # [object] Kafka source properties topic: DATAPATH-TELEMETRY-RECORD - kafka.bootstrap.servers: "192.168.40.147:9094" + kafka.bootstrap.servers: "192.168.44.12:9094" kafka.session.timeout.ms: 60000 kafka.max.poll.records: 3000 kafka.max.partition.fetch.bytes: 31457280 diff --git a/groot-examples/pom.xml b/groot-examples/pom.xml index bbc9c65..d6cf698 100644 --- a/groot-examples/pom.xml +++ b/groot-examples/pom.xml @@ -18,7 +18,7 @@ </modules> <properties> - <scope>provided</scope> + <scope>compile</scope> </properties> <dependencies> |