feat: allow format plain encode bytes for Nats connector (#15806)

Signed-off-by: tabVersion <[email protected]>
risingwavelabs · Mar 20, 2024 · ab5b7bc · ab5b7bc
1 parent 0188945
commit ab5b7bc
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/frontend/src/handler/create_source.rs b/src/frontend/src/handler/create_source.rs
@@ -1012,7 +1012,7 @@ static CONNECTORS_COMPATIBLE_FORMATS: LazyLock<HashMap<String, HashMap<Format, V
                     Format::DebeziumMongo => vec![Encode::Json],
                 ),
                 NATS_CONNECTOR => hashmap!(
-                    Format::Plain => vec![Encode::Json, Encode::Protobuf],
+                    Format::Plain => vec![Encode::Json, Encode::Protobuf, Encode::Bytes],
                 ),
                 MQTT_CONNECTOR => hashmap!(
                     Format::Plain => vec![Encode::Json, Encode::Bytes],