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

Reply via email to