gfwleak/galaxy-deployment-updata-record
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

CN Groot-Stream 24.04

Browse Source
This commit is contained in:
gujinkai
2024-05-20 11:16:43 +08:00
parent 237fa504e5
commit c5a63cc33e
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
cyber_narrator/upgrade/2024/CN-24.04/groot_stream/etl_session_record_kafka_to_cn_kafka
View File

@@ -3,7 +3,7 @@ sources:
type: kafka type: kafka
# fields: # [array of object] Field List, if not set, all fields(Map<String, Object>) will be output. # fields: # [array of object] Field List, if not set, all fields(Map<String, Object>) will be output.
properties: # [object] Source Properties properties: # [object] Source Properties
topic: SESSION-RECORD-PROCESSED topic: {{ tsg_olap_kafka_session_record_or_session_record_processed_topic }} # SESSION-RECORD/SESSION-RECORD-PROCESSED
kafka.bootstrap.servers: {{ tsg_olap_kafka_servers }} kafka.bootstrap.servers: {{ tsg_olap_kafka_servers }}
kafka.session.timeout.ms: 60000 kafka.session.timeout.ms: 60000
kafka.max.poll.records: 3000 kafka.max.poll.records: 3000
@@ -11,7 +11,7 @@ sources:
kafka.security.protocol: SASL_PLAINTEXT kafka.security.protocol: SASL_PLAINTEXT
kafka.sasl.mechanism: PLAIN kafka.sasl.mechanism: PLAIN
kafka.sasl.jaas.config: 454f65ea6eef1256e3067104f82730e737b68959560966b811e7ff364116b03124917eb2b0f3596f14733aa29ebad9352644ce1a5c85991c6f01ba8a5e8f177a7ff0b2d3889a424249967b3870b50993d9644f239f0de82cdb13bdb502959e16afadffa49ef1e1d2b9c9b5113e619817 kafka.sasl.jaas.config: 454f65ea6eef1256e3067104f82730e737b68959560966b811e7ff364116b03124917eb2b0f3596f14733aa29ebad9352644ce1a5c85991c6f01ba8a5e8f177a7ff0b2d3889a424249967b3870b50993d9644f239f0de82cdb13bdb502959e16afadffa49ef1e1d2b9c9b5113e619817
kafka.group.id: etl_processed_session_record_kafka_to_cn_kafka kafka.group.id: etl_session_record_kafka_to_cn_kafka
kafka.auto.offset.reset: latest kafka.auto.offset.reset: latest
format: json format: json
@@ -369,7 +369,7 @@ sinks:
application: application:
env: env:
name: etl_session_record_processed_kafka_to_cn_kafka name: etl_session_record_kafka_to_cn_kafka
shade.identifier: aes shade.identifier: aes
pipeline: pipeline:
object-reuse: true object-reuse: true