0

Kubernetes での NATS ストリーミング用の非常に基本的なアプリケーションをテストしたかったのです。そのために、公式の NATS-docs のコマンドに従いました

それは基本的に実行に帰着します

kubectl apply -f https://raw.githubusercontent.com/nats-io/k8s/master/nats-server/single-server-nats.yml
kubectl apply -f https://raw.githubusercontent.com/nats-io/k8s/master/nats-streaming-server/single-server-stan.yml

クラスターにアクセスできる端末で(私の場合は一種のクラスターです)。

stan.goNATS-streaming-client として使用しました。NATS-streaming-server に接続しようとしたコードは次のとおりです。

package main

import stan "github.com/nats-io/stan.go"

func main() {
    sc, err := stan.Connect("stan", "test-client")

    if err != nil {
        panic(err)
    }
    if err := sc.Publish("test-subject", []byte("This is a test-message!")); err != nil {
        panic(err)
    }
}

これは私が得ているエラーです:

panic: nats: no servers available for connection

goroutine 1 [running]:
main.main()
    /Users/thilt/tmp/main.go:9 +0x15d
exit status 2

そのため、クラスターなどに別の名前が使用されたと思います。上記の docs.nats-link から提供された例を使用するとnats-box、それも機能しません! ここでどこが間違っていたのですか?

必要に応じて、喜んでさらに情報を提供します。

4

1 に答える 1