The pulsar-game from labuladong

Hi there 👋

我是 labuladong，拥抱开源，创造价值，致力于把复杂的问题讲清楚。

欢迎学习我的算法教程：

https://labuladong.online/algo/

pulsar-game's People

Contributors

Stargazers

Watchers

pulsar-game's Issues

client.CreateProducer 创建Producer失败

main.go函数如下：

const privateKeyPath = "o-akmwo-zane.json"
const pulsarUrl = "pulsar+ssl://cluster-zane.o-akmwo.snio.cloud:6651"

func main() {
	ebiten.SetWindowSize(screenWidth, screenHeight)
	ebiten.SetWindowTitle("Bomb man")
        ......
}

集群配置如下：

oauthConfig参数根据自己的集群做了一定的调整，如下图：

修改后的代码如下，仅调整了oauthConfig部分，认证部分是可以通过的：

func newPulsarClient(topicName, subscriptionName, keyPath string) *pulsarClient {
	oauthConfig := map[string]string{
		"type":       "client_credentials",
		"issuerUrl":  "https://auth.streamnative.cloud/",
		"audience":   "urn:sn:pulsar:o-akmwo:gcloud-zane",
		"privateKey": keyPath,
		"clientId":   "ACy6fIueFvVSpaqSEJUL8IMkuwcrHMFf",
	}
	oauth := pulsar.NewAuthenticationOAuth2(oauthConfig)
	client, err := pulsar.NewClient(pulsar.ClientOptions{
		URL:            pulsarUrl,
		Authentication: oauth,
	})
	if err != nil {
		log.Fatal(err)
	}

	// player event topicName
	producer, err := client.CreateProducer(pulsar.ProducerOptions{
		Topic:           topicName,
		DisableBatching: true,
	})
	if err != nil {
		log.Fatalf("client.CreateProducer err: %s", err)
	}