Ошибка при подключении к NATS с помощью go
Я пытаюсь создать издателя для NATS с watermill, NATS сервер запустил как в документации:
docker run --name nats --network nats --rm -p 4222:4222 -p 8222:8222 nats --http_port 8222 --cluster_name test-cluster --cluster nats://0.0.0.0:6222
Все запустилось, в консоли пишет [INF] Cluster name is test-cluster
Код подключения выглядит таким образом:
publisher, err := nats.NewStreamingPublisher(
nats.StreamingPublisherConfig{
ClusterID: "test-cluster",
ClientID: "test",
StanOptions: []stan.Option{stan.NatsURL("nats://localhost:4222")},
Marshaler: nats.GobMarshaler{},
}, logger,
)
if err != nil {
return err
}
и возвращает ошибку: cannot connect to nats: stan: connect request timeout (possibly wrong cluster ID?)
В чем может быть проблема?
использую вот эту либу: https://github.com/ThreeDotsLabs/watermill-nats