我尝试使用以下命令在我的 ubuntu 22.04 上运行一个进程的 pprof:go tool pprof http://localhost:9091/debug/pprof/profile,当目标进程以轻量级运行时
我尝试使用以下命令获取在我的 ubuntu 22.04 上运行的一个进程的 pprof: go tool pprof http://localhost:9091/debug/pprof/profile
好吧,当目标进程在轻负载下运行时,这个命令可以给我一个有效的 pprof 结果,但这毫无意义。
当目标进程运行繁忙时,正如我所料,消耗了大约 200% 的 CPU。 上面的命令将卡住并且根本无法结束。
ENV:unbuntu 22.04go:1.22.3pprof:最新安装(go install github.com/google/pprof@latest)
我尝试获取卡住的 pprof 的堆栈,如下所示:
#0 runtime.futex () at /usr/local/go/src/runtime/sys_linux_amd64.s:558
#1 0x0000000000439bf0 in runtime.futexsleep (addr=0xfffffffffffffe00, val=0, ns=4671651) at /usr/local/go/src/runtime/os_linux.go:69
#2 0x0000000000411ac7 in runtime.notesleep (n=0xd2c5c0 <runtime.m0+320>) at /usr/local/go/src/runtime/lock_futex.go:170
#3 0x0000000000445133 in runtime.mPark () at /usr/local/go/src/runtime/proc.go:1761
#4 runtime.stoplockedm () at /usr/local/go/src/runtime/proc.go:3026
#5 0x000000000044745a in runtime.schedule () at /usr/local/go/src/runtime/proc.go:3847
#6 0x0000000000447aac in runtime.park_m (gp=0xc0001be380) at /usr/local/go/src/runtime/proc.go:4036
#7 0x0000000000470a6e in runtime.mcall () at /usr/local/go/src/runtime/asm_amd64.s:458
#8 0x00007fff5315c688 in ?? ()
#9 0x00000000004753ff in runtime.newproc (fn=0x47096f <runtime.rt0_go+303>) at <autogenerated>:1
#10 0x00000000004709e5 in runtime.mstart () at /usr/local/go/src/runtime/asm_amd64.s:394
#11 0x000000000047096f in runtime.rt0_go () at /usr/local/go/src/runtime/asm_amd64.s:358
#12 0x0000000000000002 in ?? ()
#13 0x00007fff5315c6d8 in ?? ()
#14 0x00007fff5315c6d0 in ?? ()
#15 0x0000000000000002 in ?? ()
#16 0x00007fff5315c6d8 in ?? ()
#17 0x0000777de028b2ca in _dl_start_user () from /lib64/ld-linux-x86-64.so.2
#18 0x0000000000000002 in ?? ()
#19 0x00007fff5315da7b in ?? ()
#20 0x00007fff5315daa4 in ?? ()
#21 0x0000000000000000 in ?? ()
看起来 pprof 正在按照计划休眠,很难知道原因。
我确信这个卡住和工作负载有关,因为当通过在客户端设置睡眠时间(例如“sleep(10)”)来调整工作负载时,pprof 也会卡住一段时间,但最终可以返回结果。
有人有处理过此类案件吗?
我正在使用 Golang 与 Kafka 消费者合作。之前有一个消费者代码库,它在消费者组为 consumer-1 的服务器上运行,并且该消费者中有大量数据,以至于
我正在使用 Golang 与 Kafka 消费者合作。之前有一个消费者代码库,它在带有消费者组的服务器上运行 consumer-1
,并且该消费者中有很多数据,因此读取工作正常。但现在我正在创建一个具有相同组 ID 的新消费者,并在配置下进行了一些调整,但它没有收到消息。
代码库
reader := kafka.NewReader(kafka.ReaderConfig{
Brokers: []string{config.KAFKA.Broker},
Topic: newTopic,
MaxBytes: 10485760,
GroupID: "consumer-1",
MaxWait: time.Duration(2 * time.Second),
ReadBatchTimeout: time.Duration(2 * time.Second),
QueueCapacity: 10000,
// Dialer: dailer,
})
我正在使用的库
"github.com/segmentio/kafka-go"
这是我在之前的代码中所做的配置,是一样的。为什么这不起作用?