apache / apache/pulsar-client-go

When the topic is deleted, call consumer.Close() program panic

Open
#1,001 1 comment 0 reactions 1 assignee Claimed by @shibd View on GitHub
Dominant language
Go
Stars
745
Forks
389
Avg merge
3d 20h
Merged PRs (30d)
3

Description

1. client.Subscribe create consumer
2. delete the topic on the console
3. consumer call Close() close the consumer and panic

panic: runtime error: invalid memory address or nil pointer dereference
[signal SIGSEGV: segmentation violation code=0x1 addr=0x18 pc=0xe9fab4]

goroutine 54085 [running]:
mq-proxy/vendor/github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).getConsumerState(...)
/var/jenkins_home/workspace/cci-905269-131348/ci-workspace/src/mq-proxy/vendor/github.com/apache/pulsar-client-go/pulsar/consumer_partition.go:466
mq-proxy/vendor/github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).Close(...)
/var/jenkins_home/workspace/cci-905269-131348/ci-workspace/src/mq-proxy/vendor/github.com/apache/pulsar-client-go/pulsar/consumer_partition.go:475
cmq-proxy/vendor/github.com/apache/pulsar-client-go/pulsar.(*consumer).Close.func1.1(0xc000377260)
/var/jenkins_home/workspace/cci-905269-131348/ci-workspace/src/mq-proxy/vendor/github.com/apache/pulsar-client-go/pulsar/consumer_impl.go:568 +0x54
created by mq-proxy/vendor/github.com/apache/pulsar-client-go/pulsar.(*consumer).Close.func1
/var/jenkins_home/workspace/cci-905269-131348/ci-workspace/src/mq-proxy/vendor/github.com/apache/pulsar-client-go/pulsar/consumer_impl.go:566 +0xb9

This is unreasonable. For example, the administrator deletes a user, the user loginout, causing the system to crash

Contributor guide

Open the contributing guide

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.