Receive message from downstream topic when publish message to upstream topic

[Lazy-Guys]

Hey, guys, I have a problem when I tried to write a mapper. When I tried to publish messages to upstream topic, I also received messages from downstream topic. At the same time, there is a certain probability to trigger invalid address panic. Besides, after I updated device twins about 5 mins, I would receive many messages from downstream topic. During all the operations, I did not edit anything in cloud. Any help to solve this problem?

log info:

Here is the panic:

Here is the repeated message from downstream topic:

Here is my code to publish message:

Here is part of code to subscribe message:

KubeEdge version: v1,11,2
Kubernetes version: v1.23.8
Go version: 1.12.3
CPU Arch: arm64