CREATE TABLE inputTable (
  -- Columns based on AVRO schema for kafka value
  id STRING NOT NULL,
  -- Watermark
  ingestionTime TIMESTAMP(3) METADATA FROM 'timestamp',
  WATERMARK FOR ingestionTime AS ingestionTime,
  -- computed fields
  procTime AS PROCTIME()
) WITH (
  -- connector options
  'connector' = 'kafka',
  -- etc
)