marun

https://blog.marun.run [email protected]

@Duomai Hangzhou, China

Results 13 issues of


                                            marun

Add more configurable items for loki.source.kafka

### Request 1. `config.Consumer.Offsets.Initial` config 2. `config.Consumer.Return.Errors` config ### Use case 1. I have a long-running Kafka instance that has accumulated a large amount of logs. I don't need to...

enhancement

笔误？

这里`192.168.1.70 && 255.255.255.0 = 192.168.1.64 ` 是否应该修改为 `192.168.1.70 && 255.255.255.192 = 192.168.1.64 ` 才是正确的？ https://github.com/hoochanlon/helpdesk-guide/blob/4fb99231adfd71a1d1b68a7de8d6ecb81cfb4e39/docs/enhance/net/neta.md?plain=1#L198-L208

feat : 新增任务超时时间控制以及 bug fix

增加executor.ctx executor.cancel 控制执行器的退出, 并增加执行器退出等待时间执行器退出之后不需要再重复注册执行器了增加ctx.Done()监听执行超时之后主动回调修复同时执行同名任务, 共用一个task指针会任务回调的错误

‹
1
2