fix: update configuration

config.example.yaml

@@ -2,13 +2,12 @@ logger:
   level: "debug"
 
 nats:
-  stream:
-    - name: "test"
-      subject: "test"
+  stream:         
+    - name: "stream"
+      subject: "test"   # optional
   url: "localhost:4222"
   publish_interval: 2s
   request_timeout: 50ms
-  default_subject: "test"
   max_pub_acks_inflight: 1000
   queue_subscription_group: "group"
   flush_timeout: 2s

internal/config/default.go

@@ -23,7 +23,6 @@ func Default() Config {
 			URL:                    "localhost:4222",
 			PublishInterval:        2 * time.Second,
 			RequestTimeout:         50 * time.Millisecond,
-			DefaultSubject:         "test",
 			MaxPubAcksInflight:     1000,
 			QueueSubscriptionGroup: "group",
 			FlushTimeout:           2 * time.Second,

internal/natsclient/config.go

@@ -7,7 +7,6 @@ type Config struct {
 	URL                    string        `json:"url,omitempty"            koanf:"url"`
 	PublishInterval        time.Duration `json:"publish_interval" koanf:"publish_interval"`
 	RequestTimeout         time.Duration `json:"request_timeout" koanf:"request_timeout"`
-	DefaultSubject         string        `json:"default_subject" koanf:"default_subject"`
 	MaxPubAcksInflight     int           `json:"max_pub_acks_inflight" koanf:"max_pub_acks_inflight"`
 	QueueSubscriptionGroup string        `json:"queue_subscription_group" koanf:"queue_subscription_group"`
 	FlushTimeout           time.Duration `json:"flush_timeout" koanf:"flush_timeout"`