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