tables:
  - name: TestTable
    type: source
    schema:
      - name: state
        type: INT
      - name: number
        type: INT
    connector:
      property-version: 1
      type: kafka
      version: 0.11
      topic: test_flink_state_check
      startup-mode: earliest-offset
      properties:
        - key: zookeeper.connect
          value: zookeeper01.xxxx.xxxxxx.com:2181
        - key: bootstrap.servers
          value: kafka01.xxxx.xxxxxx.com:9092
        - key: group.id
          value: test_flink_sql_01
        - format:
             property-version: 1
             type: json
             schema: "ROW(state INT, number INT)"

execution:
  # 'batch' or 'streaming' execution
  type: streaming
  # allow 'event-time' or only 'processing-time' in sources
  time-characteristic: processing-time
  # 'changelog' or 'table' presentation of results
  result-mode: table
  # parallelism of the program
  parallelism: 1
  # maximum parallelism
  max-parallelism: 128
  # minimum idle state retention in ms
  min-idle-state-retention: 0
  # maximum idle state retention in ms
  max-idle-state-retention: 0

deployment:
  # general cluster communication timeout in ms
  response-timeout: 5000
  # (optional) address from cluster to gateway
  gateway-address: ""
  # (optional) port from cluster to gateway
  gateway-port: 0