diff --git a/pubsub/jetstream/jetstream.go b/pubsub/jetstream/jetstream.go
index 51f1f10a0..3965cb0a5 100644
--- a/pubsub/jetstream/jetstream.go
+++ b/pubsub/jetstream/jetstream.go
@@ -68,7 +68,17 @@ func (js *jetstreamPubSub) Init(metadata pubsub.Metadata) error {
 	}
 	js.l.Debugf("Connected to nats at %s", js.meta.natsURL)
 
-	js.jsc, err = js.nc.JetStream(nats.Domain(js.meta.domain), nats.APIPrefix(js.meta.apiPrefix))
+	jsOpts := []nats.JSOpt{}
+
+	if js.meta.domain != "" {
+		jsOpts = append(jsOpts, nats.Domain(js.meta.domain))
+	}
+
+	if js.meta.apiPrefix != "" {
+		jsOpts = append(jsOpts, nats.APIPrefix(js.meta.apiPrefix))
+	}
+
+	js.jsc, err = js.nc.JetStream(jsOpts...)
 	if err != nil {
 		return err
 	}