sarama-cluster之panic: non-positive interval for NewTicker 问题

go 常见问题记录

// 报错样式：
panic: non-positive interval for NewTickergoroutine 59 [running]:
time.NewTicker(0x0, 0x0)D:/Go/src/time/tick.go:23 +0x14e
github.com/bsm/sarama-cluster.(*Consumer).cmLoop(0xc000212000, 0xc0002ba1e0)D:/work/mygo/pkg/mod/github.com/bsm/sarama-cluster@v2.1.15+incompatible/consumer.go:452 +0x61
github.com/bsm/sarama-cluster.(*loopTomb).Go.func1(0xc0002982a0, 0xc000288230)D:/work/mygo/pkg/mod/github.com/bsm/sarama-cluster@v2.1.15+incompatible/util.go:73 +0x82
created by github.com/bsm/sarama-cluster.(*loopTomb).GoD:/work/mygo/pkg/mod/github.com/bsm/sarama-cluster@v2.1.15+incompatible/util.go:69 +0x6d
//处理1： 找到这个consumer.go源码位置，上面的第二个报错有标注位置
github.com/bsm/sarama-cluster.(*Consumer).cmLoop(0xc000212000, 0xc0002ba1e0)D:/work/mygo/pkg/mod/github.com/bsm/sarama-cluster@v2.1.15+incompatible/consumer.go:452 +0x61


// 修改452行，//    ticker := time.NewTicker(c.client.config.Consumer.Offsets.CommitInterval)ticker := time.NewTicker(c.client.config.Consumer.Offsets.AutoCommit.Interval)

// 保存重新build即可

另有方案：把 sarama 版本改成 从 v1.26.1 --> v1.24.1 就可以用啦 github.com/Shopify/sarama v1.24.1gomod 的配置改下版本号就可以
github.com/Shopify/sarama v1.24.1github.com/bsm/sarama-cluster v2.1.15+incompatible

参考： sarama-cluster消费者运行时报panic

sarama-cluster之panic: non-positive interval for NewTicker 问题相关推荐

sarama-cluster消费者运行时报panic: non-positive interval for NewTicker
笔者是go新手,照着例子运行customer代码如下: package mainimport (_"flag""fmt""log"" ...
golang time.NewTimer ,time.After, time.NewTicker
常见问题: time.After 误用比如如下功能,实现goroutine 在2秒后退出.下面 demo1 package mainimport "time"func main( ...
elasticsearch 监控
本文主要讲述使用 Prometheus监控ES,梳理核心监控指标并构建 Dashboard ,当集群有异常或者节点发生故障时,可以根据性能图表以高效率的方式进行问题诊断,再对核心指标筛选添加告警通常 ...
c语言定时器作用,Go语言定时器实现原理及作用
对于任何一个正在运行的应用,如何获取准确的绝对时间都非常重要,但是在一个分布式系统中我们很难保证各个节点上绝对时间的一致性,哪怕通过 NTP 这种标准的对时协议也只能把时间的误差控制在毫秒级,所以相对 ...
机器学习基石笔记5——为什么机器可以学习（1）
转载请注明出处:http://www.cnblogs.com/ymingjingr/p/4271742.html 目录机器学习基石笔记1--在何时可以使用机器学习(1) 机器学习基石笔记2--在何时 ...
Go语言计时器的使用详解
Go语言计时器 Go语言的标准库里提供两种类型的计时器Timer和Ticker.Timer经过指定的duration时间后被触发,往自己的时间channel发送当前时间,此后Timer不再计时.Tic ...
详解Go语言的计时器
Go语言的标准库里提供两种类型的计时器Timer和Ticker.Timer经过指定的duration时间后被触发,往自己的时间channel发送当前时间,此后Timer不再计时.Ticker则是每隔d ...
【clickhouse】 clickhouse配置查询记录query_log
1.概述转载:clickhouse配置查询记录query_log 最近在使用clickhouse中,看到官方文档上可以配置query_log,但是文档上写的配置比较模糊,特此记录一下具体配置方法,以 ...
winform 让他间隔一段时间执行事件且只执行一次_记一次golang定时器引发的诡异错误...
作为一只在9127工作制下摸鱼的程序猿,周六自然是愉快的加班了.一早上除了一位新同学在我们的"敏捷迭代"下错删了接口之外没什么大事. 临近中午,突然隔壁组大佬找到我,表示有个go语 ...

sarama-cluster之panic: non-positive interval for NewTicker 问题

sarama-cluster之panic: non-positive interval for NewTicker 问题相关推荐

最新文章

热门文章