Add parameter in MQTT sink (#99)

* Update mqtt.mdx * Update mqtt.mdx * topic should be optional
risingwavelabs · Dec 2, 2024 · 96b042e · 96b042e
1 parent dbf7930
commit 96b042e
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/integrations/destinations/mqtt.mdx b/integrations/destinations/mqtt.mdx
@@ -69,6 +69,7 @@ After the sink is created, you will continuously consume the data in the MQTT to
 | inflight\_messages | Optional. Maximum number of inflight messages. Defaults to 100.                                                                                                                                                                                       |
 | tls.client\_cert   | Optional. Path to the client's certificate file (PEM) or a string with the certificate content. Required for client authentication. Can use `fs://` prefix for file paths.                                                                              |
 | tls.client\_key    | Optional. Path to the client's private key file (PEM) or a string with the private key content. Required for client authentication. Can use `fs://` prefix for file paths.                                                                              |
-| topic              | Required. The topic name to subscribe or publish to. Can include wildcard topics, e.g., `/topic/#`.                                                                                                                                                     |
+| topic              | Optional. The topic name to subscribe or publish to. Can include wildcard topics, e.g., `/topic/#`.                                                                                                                                                     |
+| topic.field | Optional. Enables dynamic writing to multiple topics based on the value of a specified column. If set, the target topic is the value of this column.|
 | retain             | Optional. Whether the message should be retained by the broker.                                                                                                                                                                                       |
 | r#type             | Required. Type identifier.                                                                                                                                                                                                                            |