CREATE TABLE outputTable (
  -- Columns based on AVRO schema for kafka value
  id STRING NOT NULL,
  firstName STRING NOT NULL,
  lastName STRING NOT NULL,
  date_of_birth STRING NOT NULL,
  -- Watermark
  ingestionTime TIMESTAMP(3) METADATA FROM 'timestamp',
  WATERMARK FOR ingestionTime AS ingestionTime
) WITH (
  -- connector options
  'connector' = 'kafka',
  -- etc
)