Connecting NATS eventsource to an external NATS stream queue.

[JAtula]

So i've setup a NATS (stan) stream server in kubernetes cluster a, and would like to use it as a NATS-type event source that would run in cluster b. NATS runs fine, and I can connect to it using a go client from where ever, but the eventsource handler keeps failing:

{"level":"info","ts":1617192251.413187,"logger":"argo-events.eventsource","caller":"eventsources/eventing.go:361","msg":"Eventing server started.","eventSourceName":"nats"}
{"level":"info","ts":1617192251.413266,"logger":"argo-events.eventsource","caller":"eventsources/eventing.go:286","msg":"starting eventbus connection daemon...","eventSourceName":"nats"}
{"level":"info","ts":1617192251.4133801,"logger":"argo-events.eventsource","caller":"nats/start.go:67","msg":"connecting to nats cluster...","eventSourceName":"nats","eventSourceType":"nats","eventName":"build"}
{"level":"info","ts":1617192280.0219986,"logger":"argo-events.eventsource","caller":"nats/start.go:67","msg":"connecting to nats cluster...","eventSourceName":"nats","eventSourceType":"nats","eventName":"build"}
{"level":"info","ts":1617192296.7770867,"logger":"argo-events.eventsource","caller":"nats/start.go:67","msg":"connecting to nats cluster...","eventSourceName":"nats","eventSourceType":"nats","eventName":"build"}
{"level":"info","ts":1617192333.3797424,"logger":"argo-events.eventsource","caller":"nats/start.go:67","msg":"connecting to nats cluster...","eventSourceName":"nats","eventSourceType":"nats","eventName":"build"}
{"level":"info","ts":1617192357.165178,"logger":"argo-events.eventsource","caller":"nats/start.go:67","msg":"connecting to nats cluster...","eventSourceName":"nats","eventSourceType":"nats","eventName":"build"}
{"level":"info","ts":1617192389.9766326,"logger":"argo-events.eventsource","caller":"nats/start.go:67","msg":"connecting to nats cluster...","eventSourceName":"nats","eventSourceType":"nats","eventName":"build"}
{"level":"info","ts":1617192408.896194,"logger":"argo-events.eventsource","caller":"nats/start.go:67","msg":"connecting to nats cluster...","eventSourceName":"nats","eventSourceType":"nats","eventName":"build"}
{"level":"info","ts":1617192436.9351063,"logger":"argo-events.eventsource","caller":"nats/start.go:67","msg":"connecting to nats cluster...","eventSourceName":"nats","eventSourceType":"nats","eventName":"build"}
{"level":"info","ts":1617192461.9615934,"logger":"argo-events.eventsource","caller":"nats/start.go:67","msg":"connecting to nats cluster...","eventSourceName":"nats","eventSourceType":"nats","eventName":"build"}
{"level":"info","ts":1617192476.0986183,"logger":"argo-events.eventsource","caller":"nats/start.go:67","msg":"connecting to nats cluster...","eventSourceName":"nats","eventSourceType":"nats","eventName":"build"}
{"level":"error","ts":1617192482.1585858,"logger":"argo-events.eventsource","caller":"eventsources/eventing.go:355","msg":"failed to start listening eventsource","eventSourceName":"nats","eventSourceType":"nats","eventName":"build","error":"timed out waiting for the condition","stacktrace":"github.com/argoproj/argo-events/eventsources.(*EventSourceAdaptor).Start.func3\n\t/home/runner/work/argo-events/argo-events/eventsources/eventing.go:355"}
{"level":"error","ts":1617192482.1586819,"logger":"argo-events.eventsource","caller":"eventsources/eventing.go:378","msg":"Erroring out, no active event server running","eventSourceName":"nats","stacktrace":"github.com/argoproj/argo-events/eventsources.(*EventSourceAdaptor).Start\n\t/home/runner/work/argo-events/argo-events/eventsources/eventing.go:378\nmain.main\n\t/home/runner/work/argo-events/argo-events/eventsources/cmd/main.go:58\nruntime.main\n\t/opt/hostedtoolcache/go/1.14.15/x64/src/runtime/proc.go:203"}

Kube clusters running AWS, NATS stream behind an Nginx ingress controller (NLB) with TCP pass through.

I'm using nkeys to authenticate.

[whynowy]

What version of argo-events are you running? I believe connecting to NATS with authentication is only supported in v1.3.x version (currently v1.3.0-rc2 is available).