Keto
Keto
As the title discribed
我明白日志收集是按行收集的,收集后会封装成为一个json格式并且推送给kafka, 但是这意味着,我实际日志无论再小,都会因为封装变得很大 ``` { //....... 额外信息 message:"hello world", //...... 额外信息 } ``` 我发现额外信息竟然达到惊人的1k,其序列化,组装和压缩给日志收集主机的计算造成了挑战,请问有什么办法可以通过配置来定义额外信息的选择性发送么?
code in decimal ``` func (d Decimal) NumDigits() int { // Note(mwoss): It can be optimized, unnecessary cast of big.Int to string if d.IsNegative() { return len(d.value.String()) - 1 }...
Allocate too many objects from heap when modify the skiplist ``` make([]*node, s.level()+1, s.effectiveMaxLevel()) ``` Any idea to improve it?
### Describe the bug When i do s3 object writing. open the logger, it output something i don't expect: ``` [2023-03-03 03:07:43.722] [info] AwsSdk | *Debug* (HeaderIn) x-amz-request-id: 74YE1D4KDD18G374 [2023-03-03...
### Describe the feature rate limit for STSAssumeRoleWithWebIdentityRequest, so i want to get longer sessions via STS ### Use Case rate limit for STSAssumeRoleWithWebIdentityRequest, so i want to get longer...
Hello there! Our system generates a large amount of logs, each containing many unused fields. If we use the following json filter: ``` filter { json { source => "message"...
#### Description: After upgrading Kafka from version 2.2.1 to 3.5.1, we observed issues related to leader switching. The specific issues and reproduction steps are as follows: #### Process: 1. During...
**Describe the bug** When I close the reader, it stuck at the `batch.Close()` until it reach `readBatchTimeout` ``` func (r *reader) read(ctx context.Context, offset int64, conn *Conn) (int64, error) {...