SIGABRT on querying watermark offsets #5160
Description
I use confluent-kafka-go 2.11.0 and run consumer.QueryWatermarkOffsets method quite often in my app.
Every time i do rolling update on my Kafka Brokers - all my production app instances crashes. Which may lead to service unavailability.
Golang doesn't provide way to prevent from crashing in such cases that is why i create issue in here.
Error log:
Assertion failed: (r == 0), function rwlock_rdlock, file tinycthread_extra.c, line 175.
SIGABRT: abort
PC=0x18f346388 m=8 sigcode=0
signal arrived during cgo execution
goroutine 331 gp=0x14000405500 m=8 mp=0x14000580008 [syscall]:
runtime.cgocall(0x102486ef0, 0x14000630788)
/Users/ildarnurislamov/go/pkg/mod/golang.org/[email protected]/src/runtime/cgocall.go:167 +0x44 fp=0x14000630750 sp=0x14000630710 pc=0x100311a64
github.com/confluentinc/confluent-kafka-go/v2/kafka._Cfunc_rd_kafka_query_watermark_offsets(0x11302f200, 0x60000254cab0, 0x0, 0x14000c7e3d8, 0x14000c7e400, 0x2710)
_cgo_gotypes.go:4923 +0x34 fp=0x14000630780 sp=0x14000630750 pc=0x10047e404
github.com/confluentinc/confluent-kafka-go/v2/kafka.queryWatermarkOffsets.func2(...)
/Users/ildarnurislamov/go/pkg/mod/github.com/confluentinc/confluent-kafka-go/[email protected]/kafka/metadata.go:150
github.com/confluentinc/confluent-kafka-go/v2/kafka.queryWatermarkOffsets({0x1058db0c0?, 0x14000678680?}, {0x1400031a240, 0x27}, 0x0, 0x2710)
/Users/ildarnurislamov/go/pkg/mod/github.com/confluentinc/confluent-kafka-go/[email protected]/kafka/metadata.go:150 +0x10c fp=0x14000630860 sp=0x14000630780 pc=0x1004a05fc
github.com/confluentinc/confluent-kafka-go/v2/kafka.(*Consumer).QueryWatermarkOffsets(0x0?, {0x1400031a240?, 0x0?}, 0x0?, 0x9?)
I believe admin client's offset-related methods are also affected by this issue. So it may be more widespread problem.