[filter] rules = ['foo*.*', 'bar*.*'] [[sink.dispatchers]] matcher = ['db1.*', 'db2.*', 'db3.*'] dispatcher = 'ts' 13.7.9.2 Syntax 13.7.9.2.1 Plain table names Each table filter rule consists of a “schema sent to the default topic. • For tables that match the matcher rule but do not specify a topic dispatcher, the corresponding data changes are sent to the default topic specified in --sink-uri. For example is sent to the default topic. Topic dispatchers You can use topic = “xxx” to specify a Topic dispatcher and use topic expressions to implement flexible topic dispatching policies. It is recommended that

[filter] rules = ['foo*.*', 'bar*.*'] [[sink.dispatchers]] matcher = ['db1.*', 'db2.*', 'db3.*'] dispatcher = 'ts' 13.7.9.2 Syntax 13.7.9.2.1 Plain table names Each table filter rule consists of a “schema sent to the default topic. • For tables that match the matcher rule but do not specify a topic dispatcher, the corresponding data changes are sent to the default topic specified in --sink-uri. For example is sent to the default topic. Topic dispatchers You can use topic = “xxx” to specify a Topic dispatcher and use topic expressions to implement flexible topic dispatching policies. It is recommended that

[filter] rules = ['foo*.*', 'bar*.*'] [[sink.dispatchers]] matcher = ['db1.*', 'db2.*', 'db3.*'] dispatcher = 'ts' 13.7.9.2 Syntax 13.7.9.2.1 Plain table names Each table filter rule consists of a “schema sent to the default topic. • For tables that match the matcher rule but do not specify a topic dispatcher, the corresponding data changes are sent to the default topic specified in --sink-uri. For example is sent to the default topic. Topic dispatchers You can use topic = “xxx” to specify a Topic dispatcher and use topic expressions to implement flexible topic dispatching policies. It is recommended that

[filter] rules = ['foo*.*', 'bar*.*'] [[sink.dispatchers]] matcher = ['db1.*', 'db2.*', 'db3.*'] dispatcher = 'ts' 13.7.10.2 Syntax 13.7.10.2.1 Plain table names Each table filter rule consists of a “schema sent to the default topic. • For tables that match the matcher rule but do not specify a topic dispatcher, the corresponding data changes are sent to the default topic specified in --sink-uri. For example is sent to the default topic. Topic dispatchers You can use topic = “xxx” to specify a Topic dispatcher and use topic expressions to implement flexible topic dispatching policies. It is recommended that

sent to the default topic. • For tables that match the matcher rule but do not specify a topic dispatcher, the corresponding data changes are sent to the default topic specified in --sink-uri. For example is sent to the default topic. Topic dispatchers You can use topic = “xxx” to specify a Topic dispatcher and use topic expressions to implement flexible topic dispatching policies. It is recommended that corresponding to table-level DDLs are sent to the corresponding topic according to dispatcher configurations. For example, for a dispatcher like matcher = ['test.*'], topic = {schema}_{table �→ }, DDL events are

[filter] rules = ['foo*.*', 'bar*.*'] [[sink.dispatchers]] matcher = ['db1.*', 'db2.*', 'db3.*'] dispatcher = 'ts' 13.7.11.2 Syntax 13.7.11.2.1 Plain table names Each table filter rule consists of a “schema to the default topic. 2763 • For tables that match the matcher rule but do not specify a topic dispatcher, the corresponding data changes are sent to the default topic specified in --sink-uri. For example is sent to the default topic. Topic dispatchers You can use topic = “xxx” to specify a Topic dispatcher and use topic expressions to implement flexible topic dispatching policies. It is recommended that

[filter] rules = ['foo*.*', 'bar*.*'] [[sink.dispatchers]] matcher = ['db1.*', 'db2.*', 'db3.*'] dispatcher = 'ts' 13.7.11.2 Syntax 13.7.11.2.1 Plain table names Each table filter rule consists of a “schema to the default topic. 2771 • For tables that match the matcher rule but do not specify a topic dispatcher, the corresponding data changes are sent to the default topic specified in --sink-uri. For example is sent to the default topic. Topic dispatchers You can use topic = “xxx” to specify a Topic dispatcher and use topic expressions to implement flexible topic dispatching policies. It is recommended that

[filter] rules = ['foo*.*', 'bar*.*'] [[sink.dispatchers]] matcher = ['db1.*', 'db2.*', 'db3.*'] dispatcher = 'ts' 13.7.11.2 Syntax 13.7.11.2.1 Plain table names Each table filter rule consists of a “schema to the default topic. 2884 • For tables that match the matcher rule but do not specify a topic dispatcher, the corresponding data changes are sent to the default topic specified in --sink-uri. For example is sent to the default topic. Topic dispatchers You can use topic = “xxx” to specify a Topic dispatcher and use topic expressions to implement flexible topic dispatching policies. It is recommended that

[filter] rules = ['foo*.*', 'bar*.*'] [[sink.dispatchers]] matcher = ['db1.*', 'db2.*', 'db3.*'] dispatcher = 'ts' 13.7.11.2 Syntax 13.7.11.2.1 Plain table names Each table filter rule consists of a “schema to the default topic. 2739 • For tables that match the matcher rule but do not specify a topic dispatcher, the corresponding data changes are sent to the default topic specified in --sink-uri. For example is sent to the default topic. Topic dispatchers You can use topic = “xxx” to specify a Topic dispatcher and use topic expressions to implement flexible topic dispatching policies. It is recommended that

[filter] rules = ['foo*.*', 'bar*.*'] [[sink.dispatchers]] matcher = ['db1.*', 'db2.*', 'db3.*'] dispatcher = 'ts' 13.7.9.2 Syntax 13.7.9.2.1 Plain table names Each table filter rule consists of a “schema sent to the default topic. • For tables that match the matcher rule but do not specify a topic dispatcher, the corresponding data changes are sent to the default topic specified in --sink-uri. For example is sent to the default topic. Topic dispatchers You can use topic = “xxx” to specify a Topic dispatcher and use topic expressions to implement flexible topic dispatching policies. It is recommended that