err = kc.Unsubscribe(context.Background(), "my_topicA", "test", myListener)