使用KAFKA协议上报日志到LTS ${accessSecret},即用户账号的AK和SK通过 连接,作为Kafka的访问密码。 ${message}日志格式 仅当headers中添加了key为LTSLOGTYPE,value为FORMAT的header时,日志需要符合该格式规范。 日志参数 参数名称 是否必选 参数类型 描述 tenantprojectid 是 String 用户账号的项目ID。 tenantgroupid 是 String LTS的日志组ID。 tenantstreamid 是 String LTS的日志流ID。 logtimens 是 Long 日志数据采集时间,UTC时间(纳秒)。 采集时间需在日志存储时间范围之内,否则上报日志会被删除。比如日志组的日志存储时间是7天,则此参数不应早于当前时间的7天前。 contents 是 Array of String 日志内容。 labels 是 Object 用户自定义label。 请不要将字段名称设置为内置保留字段,否则可能会造成字段名称重复、查询不精确等问题。 日志示例 { "tenantprojectid": "${projectId}", "tenantgroupid": "${logGroupId}", "tenantstreamid": "${logStreamId}", "logtimens": "XXXXXXXXXXXXXXXXXXX", "contents": [ "This is a log 1", "This is a log 2" ], "labels": { "type": "kafka" } } 调用示例 1. Beat系列软件调用(FileBeat等)。以FileBeat为例,配置参数如下: output.kafka: hosts: ["${ip}:${port}"] partition.roundrobin: reachableonly: false username: "${projectId}" password: "${accessKey}