使用KAFKA协议上报日志到LTS(1) 配置地址 bootstrapservers"${ip}:${port}", 配置消息确认机制 acks"0", 配置压缩方式 compressiontype "${compressiontype}" 配置认证方式 saslmechanism"PLAIN", securityprotocol"SASLPLAINTEXT", 用户名 projectId 密码 accessKey accessSecret saslplainusername"${projectId}", saslplainpassword"${accessKey} ${accessSecret}" ) print('start producer') for i in range(0, 3): data bytes("${message}", encoding"utf8") future producer.send("${logGroupId}{logStreamId}", data) result future.get(timeout10) print(result) print('end producer') 报错说明 当参数错误或不匹配时,会有相应的报错提示。 报错说明 报错信息 报错原因 TopicAuthorizationException projectId(项目ID)、accessKey(AK)、accessSecret(SK)参数错误或者不匹配。 UnknownTopicOrPartitionException logGroupId(日志组ID)、logStreamId(日志流ID)参数错误或者不匹配。 InvalidRecordException 日志格式错误或者日志中的projectId(项目ID)、logGroupId(日志组ID)、logStreamId(日志流ID)与外部设置参数不一致。
来自: