I have configured source table successfully using the following configuration:
- name: out_order
type: source
update-mode: append
schema:
- name: out_order_code
type: STRING
- name: input_date
type: BIGINT
- name: owner_code
type: STRING
connector:
property-version: 1
type: kafka
version: universal
topic: out_order
startup-mode: latest-offset
properties:
- key: zookeeper.connect
value: 172.19.78.32:2181
- key: bootstrap.servers
value: 172.19.78.32:9092
- key: group.id
property-version: 1
type: json
schema: "ROW(out_order_code STRING,owner_code STRING,input_date BIGINT)"
How can i configure a sink table? I haven't found any useful docs for this.
Thanks,
Lei