diff --git a/config.sample.yaml b/config.sample.yaml
index bed04c4..b35b636 100644
--- a/config.sample.yaml
+++ b/config.sample.yaml
@@ -43,7 +43,7 @@ stream_processing:
   # Each configuration specifies a stream processing tool to use and its settings.
   - name: "kafka-prod"
     # Type describes the type of stream processing tool to use.
-    # Supported types: "kafka", "nqs"
+    # Supported types: "kafka", "nsq"
     type: "kafka"
     # The stream type can be any of "full", "lite", "domains-only" - same as the certstream websocket urls
     # Default is "full"
@@ -58,8 +58,8 @@ stream_processing:
     # E.g. for Kafka, supported types are "none" / "", "gzip", "snappy", "lz4", "zstd"
     compression: ""
 
-  - name: "nqs-prod"
-    type: "nqs"
+  - name: "nsq-prod"
+    type: "nsq"
     stream: "lite"
     enabled: false
     server_addr: "127.0.0.1"
diff --git a/internal/config/streamprocessing.go b/internal/config/streamprocessing.go
index 7dd8478..95813c6 100644
--- a/internal/config/streamprocessing.go
+++ b/internal/config/streamprocessing.go
@@ -6,12 +6,12 @@ import (
 )
 
 // StreamProcessorType represents the type of stream processing tool to use.
-// Supported types are "kafka" and "nqs".
+// Supported types are "kafka" and "nsq".
 type StreamProcessorType string
 
 const (
 	StreamProcessorTypeKafka StreamProcessorType = "kafka"
-	StreamProcessorTypeNQS   StreamProcessorType = "nqs"
+	StreamProcessorTypeNSQ   StreamProcessorType = "nsq"
 )
 
 // StreamType represents the type of stream to process.
@@ -63,7 +63,7 @@ func (c Compression) SupportedBy(t StreamProcessorType) bool {
 	switch t {
 	case StreamProcessorTypeKafka:
 		return c == CompressionNone || c == CompressionGzip || c == CompressionSnappy || c == CompressionZstd || c == CompressionLz4
-	case StreamProcessorTypeNQS:
+	case StreamProcessorTypeNSQ:
 		return c == CompressionNone || c == CompressionDeflate || c == CompressionSnappy
 	default:
 		return false
@@ -106,7 +106,7 @@ func (s *StreamProcessor) Valid() bool {
 	}
 
 	switch s.Type {
-	case StreamProcessorTypeKafka, StreamProcessorTypeNQS:
+	case StreamProcessorTypeKafka, StreamProcessorTypeNSQ:
 	default:
 		log.Fatalf("Invalid stream processor type '%s' for name '%s'\n", s.Type, s.Name)
 		return false