diff options
| author | doufenghu <[email protected]> | 2024-02-22 19:42:36 +0800 |
|---|---|---|
| committer | doufenghu <[email protected]> | 2024-02-22 19:42:36 +0800 |
| commit | e0e35051f46744beba606bd5aea179a39e54665d (patch) | |
| tree | 3c74ff81eff1405f9fa0eb9de90cc03ab3a00147 /groot-examples | |
| parent | 8473d8e895066eacbb09fa7a0d8c3dde72d236bc (diff) | |
[Improve][Example] Add default properties for job template.
Diffstat (limited to 'groot-examples')
| -rw-r--r-- | groot-examples/end-to-end-example/src/main/resources/examples/inline_to_kafka.yaml | 27 |
1 files changed, 25 insertions, 2 deletions
diff --git a/groot-examples/end-to-end-example/src/main/resources/examples/inline_to_kafka.yaml b/groot-examples/end-to-end-example/src/main/resources/examples/inline_to_kafka.yaml index 44355c7..a70f588 100644 --- a/groot-examples/end-to-end-example/src/main/resources/examples/inline_to_kafka.yaml +++ b/groot-examples/end-to-end-example/src/main/resources/examples/inline_to_kafka.yaml @@ -31,6 +31,24 @@ sources: # [object] Define connector source json.ignore.parse.errors: false sinks: + failure_connector_kafka: + type: kafka + properties: + topic: SESSION-RECORD-TEST + kafka.bootstrap.servers: 192.168.44.121:9094 + kafka.retries: 0 + kafka.linger.ms: 10 + kafka.request.timeout.ms: 30000 + kafka.batch.size: 262144 + kafka.buffer.memory: 134217728 + kafka.max.request.size: 10485760 + kafka.compression.type: snappy + kafka.security.protocol: SASL_PLAINTEXT + kafka.sasl.mechanism: PLAIN + kafka.sasl.jaas.config: org.apache.kafka.common.security.plain.PlainLoginModule required username="admin" password="galaxy2019"; + format: json + log.failures.only: true + connector_kafka: type: kafka properties: @@ -47,6 +65,7 @@ sinks: kafka.sasl.mechanism: PLAIN kafka.sasl.jaas.config: org.apache.kafka.common.security.plain.PlainLoginModule required username="admin" password="galaxy2019"; format: json + log.failures.only: true application: # [object] Define job configuration env: @@ -57,6 +76,10 @@ application: # [object] Define job configuration object-reuse: true topology: - name: inline_source - downstream: [connector_kafka] + downstream: [failure_connector_kafka] + - name: inline_source + downstream: [ connector_kafka ] - name: connector_kafka - downstream: []
\ No newline at end of file + downstream: [] + - name: failure_connector_kafka + downstream: [ ]
\ No newline at end of file |