Create Table Monitor
Creates a monitor that watches for new records inserted into a particular table (identified by input parameter table_name) and forwards copies to subscribers via ZMQ. After this call completes, subscribe to the returned output parameter topic_id on the ZMQ table monitor port (default 9002). Each time an insert operation on the table completes, a multipart message is published for that topic; the first part contains only the topic ID, and each subsequent part contains one binary-encoded Avro object that was inserted. The monitor will continue to run (regardless of whether or not there are any subscribers) until deactivated with Clear Table Monitor.
Output Parameter Description
Name |
Type |
Description |
topic_id |
string |
The ZMQ topic ID to subscribe to for inserted
records. |
table_name |
string |
Value of input parameter table_name. |
type_schema |
string |
JSON Avro schema of the table, for use in
decoding published records. |