Anthippi commented on code in PR #10557:
URL: https://github.com/apache/seatunnel/pull/10557#discussion_r2930137728
##########
docs/en/connectors/source/Rabbitmq.md:
##########
@@ -173,8 +187,62 @@ source {
}
}
```
+### Multi-table Read Example
-## Changelog
+You can use the `table_configs` option to consume messages from multiple
RabbitMQ queues simultaneously within a single job. The connector will
automatically assign the correct table identifier to each row based on the
queue it originated from, allowing you to route them to different sinks using
`plugin_input`.
Review Comment:
Fixed, thanks
##########
docs/en/connectors/source/Rabbitmq.md:
##########
@@ -173,8 +187,62 @@ source {
}
}
```
+### Multi-table Read Example
-## Changelog
+You can use the `table_configs` option to consume messages from multiple
RabbitMQ queues simultaneously within a single job. The connector will
automatically assign the correct table identifier to each row based on the
queue it originated from, allowing you to route them to different sinks using
`plugin_input`.
-<ChangeLog />
+```hocon
+source {
+ RabbitMQ {
+ host = "localhost"
+ port = 5672
+ username = "guest"
+ password = "guest"
+
+ # Use table_configs to read from multiple queues
Review Comment:
Fixed, thanks
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
