From 8dcfb0d206a56528dc1f5f585d66f8da99df572e Mon Sep 17 00:00:00 2001 From: wangkuan Date: Mon, 22 Apr 2024 09:52:36 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9etl=5Fdatapath=5Ftelemetry=5F?= =?UTF-8?q?record=E6=91=84=E5=85=A5=E4=BB=BB=E5=8A=A1=E7=9A=84topic?= =?UTF-8?q?=E5=92=8Cformat?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../集中式/etl_datapath_telemetry_record_kafka_to_clickhouse | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/TSG发布版本更新记录/TSG-24.05/Groot-Stream/集中式/etl_datapath_telemetry_record_kafka_to_clickhouse b/TSG发布版本更新记录/TSG-24.05/Groot-Stream/集中式/etl_datapath_telemetry_record_kafka_to_clickhouse index 287faed..14655a6 100644 --- a/TSG发布版本更新记录/TSG-24.05/Groot-Stream/集中式/etl_datapath_telemetry_record_kafka_to_clickhouse +++ b/TSG发布版本更新记录/TSG-24.05/Groot-Stream/集中式/etl_datapath_telemetry_record_kafka_to_clickhouse @@ -2,7 +2,7 @@ sources: kafka_source: type: kafka properties: - topic: SESSION-RECORD + topic: DATAPATH-TELEMETRY-RECORD kafka.bootstrap.servers: 192.168.44.11:9094,192.168.44.13:9094,192.168.44.14:9094,192.168.44.15:9094,192.168.44.16:9094 kafka.session.timeout.ms: 60000 kafka.max.poll.records: 3000 @@ -19,7 +19,7 @@ sources: kafka.sasl.jaas.config: 454f65ea6eef1256e3067104f82730e737b68959560966b811e7ff364116b03124917eb2b0f3596f14733aa29ebad9352644ce1a5c85991c6f01ba8a5e8f177a7ff0b2d3889a424249967b3870b50993d9644f239f0de82cdb13bdb502959e16afadffa49ef1e1d2b9c9b5113e619817 kafka.group.id: etl_datapath_telemetry_record_kafka_to_clickhouse-20230125 kafka.auto.offset.reset: latest - format: json + format: msgpack processing_pipelines: etl_processor: # [object] Processing Pipeline